[−][src]Crate tokio_pipe
Asynchronous pipe(2) library using tokio.
Example
use tokio::prelude::*; #[tokio::main] async fn main() -> anyhow::Result<()> { let (mut r, mut w) = tokio_pipe::pipe()?; w.write_all(b"HELLO, WORLD!").await?; let mut buf = [0; 16]; let len = r.read(&mut buf[..]).await?; assert_eq!(&buf[..len], &b"HELLO, WORLD!"[..]); Ok(()) }
Structs
PipeRead | Pipe read |
PipeWrite | Pipe write |
Functions
pipe | Open pipe |