postage 0.5.0

An async channel library
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

use postage::{mpsc, oneshot, prelude::Stream, sink::Sink};

#[derive(Debug)]
enum Message {
    Str(&'static str),
    Code(usize),
}

#[tokio::main]
async fn main() {
    let (mut tx_a, rx_a) = mpsc::channel(8);
    let (mut tx_b, rx_b) = oneshot::channel();

    tx_a.send("Hello!").await.ok();
    tx_b.send(0usize).await.ok();

    let mut rx = rx_a
        // map the first reciever to a common enum type
        .map(|a| Message::Str(a))
        // map the 2nd receiver to the enum type, and then merge it with the first
        .merge(rx_b.map(|b| Message::Code(b)));

    while let Some(message) = rx.recv().await {
        println!("Sender says {:?}", message)
    }
}