dencode

支持同步和异步 io 的编码和解码帧的实用程序

包含从字节流、Read/AsyncRead 和 Write/AsyncWrite 转换到有框迭代器/流的适配器。

示例

use dencode::{LinesCodec, Framed};

async fn main() {
    // Synchronous
    // let reader = ...
    let mut framed = Framed::new(read, LinesCodec {});

    for frame in framed {
        println!("{:?}", frame);
    }

    // Asynchronous
    // let stream = ...
    let mut framed = Framed::new(stream, LinesCodec {});

    while let Some(line) = framed.try_next().await.unwrap() {
        println!("{:?}", line);
    }
}

现有技术

• futures-codec - 这个项目最初是从这个crate分叉的。
• tokio-codec