futures_codec

使用 async/await 编解码帧的实用工具。

包含将字节流、AsyncRead 和 AsyncWrite 转换为实现 Sink 和 Stream 的帧流的适配器。帧流也称为传输。

示例

use futures_codec::{LinesCodec, Framed};

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

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

lib.rs:

使用 async/await 编解码帧的实用工具。

包含将字节流、AsyncRead 和 AsyncWrite 转换为实现 Sink 和 Stream 的帧流的适配器。帧流也称为 transports。

use futures::TryStreamExt;
use futures::io::Cursor;
use futures_codec::{LinesCodec, Framed};

let io = Cursor::new(Vec::new());
let mut framed = Framed::new(io, LinesCodec);

while let Some(line) = framed.try_next().await? {
    dbg!(line);
}