async-dup

Build License Cargo Documentation

Duplicate an async I/O handle.

This crate provides two tools, Arc and Mutex:

Wrap an async I/O handle in Arc or Mutex to clone it or share among tasks.

Examples

Clone an async I/O handle:

```rust use async_dup::Arc; use futures::io; use smol::Async; use std::net::TcpStream;

// A client that echoes messages back to the server. let stream = Async::::connect("127.0.0.1:8000").await?;

// Create two handles to the stream. let reader = Arc::new(stream); let mut writer = reader.clone();

// Echo data received from the reader back into the writer. io::copy(reader, &mut writer).await?; ```

Share an async I/O handle:

```rust use async_dup::Mutex; use futures::io; use futures::prelude::*;

// Reads data from a stream and echoes it back. async fn echo(stream: impl AsyncRead + AsyncWrite + Unpin) -> io::Result { let stream = Mutex::new(stream); io::copy(&stream, &mut &stream).await } ```

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.