[−][src]Crate async_pipe
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());
Structs
PipeReader | The read half of the pipe which implements |
PipeWriter | The write half of the pipe which implements |
Functions
pipe | Creates a piped pair of an |