Duplicate an async I/O handle.
This crate provides two tools, Arc
and Mutex
:
Arc
implements AsyncRead
, AsyncWrite
, and AsyncSeek
if a reference to the inner type does.Mutex
implements AsyncRead
, AsyncWrite
, and AsyncSeek
if the inner type does.Wrap an async I/O handle in Arc
or Mutex
to clone it or share among tasks.
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::
// 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
Licensed under either of
at your option.
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.