async-duplex-channel 0.1.2

An asynchronous duplex communication channel between multiple clients and a single responder in different asynchronous blocks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use async_duplex_channel::*;
use std::time::Duration;
use tokio::runtime::Runtime;

use std::sync::Arc;
use std::sync::atomic::{AtomicU64, Ordering::*};

fn main() {
    let rt = Runtime::new().unwrap();
    rt.block_on(async {
        let (client, responder_builder) = channel(64, Duration::from_secs(2));

        let num = Arc::new(AtomicU64::new(0u64));
        let hdl = move |req: String| {
            let num = num.clone();
            async move {
                format!("{}, {}", num.fetch_add(1, Relaxed), req)
            }
        };
        let responder = responder_builder.build(hdl);

        tokio::spawn(async move {
            responder.process_requests().await.unwrap();
        });

        let resp_1 = client.request("Hello, world!".to_string()).await.unwrap();
        println!("Response: {}", resp_1);

        let resp_2 = client.request("Good Morning!".into()).await.unwrap();
        println!("Response: {}", resp_2);

        let resp_seq = client.request_batch(["A", "B", "C", "D", "E"].map(|s| s.to_string()), 4);
        println!("Response Seq: {:?}", resp_seq.await.unwrap());
    });
}