#reader-writer #writer #reader #pipe #async #future

async-pipe

Creates an asynchronous piped reader and writer pair using tokio.rs

4 releases

0.1.3 Apr 16, 2020
0.1.2 Apr 6, 2020
0.1.1 Apr 4, 2020
0.1.0 Apr 4, 2020

#1560 in Asynchronous

Download history 36/week @ 2024-03-30 15/week @ 2024-04-06 14/week @ 2024-04-13 19/week @ 2024-04-20 16/week @ 2024-04-27 15/week @ 2024-05-04 22/week @ 2024-05-11 29/week @ 2024-05-18 18/week @ 2024-05-25 22/week @ 2024-06-01 22/week @ 2024-06-08 17/week @ 2024-06-15 21/week @ 2024-06-22 20/week @ 2024-06-29 6/week @ 2024-07-06 6/week @ 2024-07-13

55 downloads per month
Used in 4 crates (3 directly)

MIT license

13KB
275 lines

async-pipe-rs

crates.io Documentation MIT

Creates an asynchronous piped reader and writer pair using tokio.rs.

Docs

Usage

First add this to your Cargo.toml:

[dependencies]
async-pipe = "0.1"

An example:

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));
}

Contributing

Your PRs and stars are always welcome.


lib.rs:

Creates an asynchronous piped reader and writer pair using tokio.rs.

Examples

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());

Dependencies

~3.5MB
~50K SLoC