async-pipe-rs

使用 tokio.rs 创建异步管道读写器对。

文档

用法

首先将以下内容添加到您的 Cargo.toml 中

[dependencies]
async-pipe = "0.1"

示例

use async_pipe;
use tokio::prelude::*;

#[tokio::main]
async fn main() {
    let (mut w, mut r) = async_pipe::pipe();

    tokio::spawn(async move {
        w.write_all(b"hello world").await.unwrap();
    });

    let mut v = Vec::new();
    r.read_to_end(&mut v).await.unwrap();
    println!("Received: {:?}", String::from_utf8(v));
}

贡献

您的 PR 和 stars 总是受欢迎的。

lib.rs:

使用 tokio.rs 创建异步管道读写器对。

示例

use async_pipe;
use tokio::prelude::*;

let (mut w, mut r) = async_pipe::pipe();
 
tokio::spawn(async move {
    w.write_all(b"hello world").await.unwrap();
});
 
let mut v = Vec::new();
r.read_to_end(&mut v).await.unwrap();

println!("Received: {:?}", String::from_utf8(v));

tokio::runtime::Runtime::new().unwrap().block_on(run());