#duplicate #clone #split #share

async-dup

Duplicate an async I/O handle

8 releases (stable)

new 1.2.3 Sep 25, 2023
1.2.2 Sep 18, 2020
1.2.1 Jul 7, 2020
1.1.0 Jun 19, 2020
0.1.0 May 31, 2020

#1176 in Asynchronous

Download history 20373/week @ 2023-06-05 19092/week @ 2023-06-12 18866/week @ 2023-06-19 17095/week @ 2023-06-26 17580/week @ 2023-07-03 16755/week @ 2023-07-10 14773/week @ 2023-07-17 15441/week @ 2023-07-24 17154/week @ 2023-07-31 14042/week @ 2023-08-07 15700/week @ 2023-08-14 17111/week @ 2023-08-21 14849/week @ 2023-08-28 15140/week @ 2023-09-04 17139/week @ 2023-09-11 15140/week @ 2023-09-18

62,996 downloads per month
Used in 191 crates (26 directly)

Apache-2.0 OR MIT

18KB
288 lines

async-dup

Build License Cargo Documentation

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.
  • A reference to 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.

Examples

Clone an async I/O handle:

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::<TcpStream>::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:

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<u64> {
    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.

Dependencies

~19KB