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
27
28
29
30
31
32
33
34
35
36

use postage::{
    mpsc,
    sink::{Sink, TrySendError},
};

#[tokio::main]
async fn main() {
    // Channel senders require mutable references to take messages.
    let (mut tx, rx) = mpsc::channel(8);

    // Senders are fallible.  If a channel is closed, there is nowhere to send the message.
    // If you want to ignore the error, you can use Result::ok
    tx.send("Hello!").await.ok();

    // If you want to check for an error, you can recover the message with `if let`
    // Let's drop rx to trigger the error.
    drop(rx);

    if let Err(message) = tx.send("This is important").await {
        println!("Failed to send a message to the receiver: {}", message);
    }

    // You can also try to send a message without blocking:
    match tx.try_send("You there?") {
        Ok(()) => {
            // the message was sent!
        }
        Err(TrySendError::Pending(_message)) => {
            // the message was returned, but it might be accepted later
        }
        Err(TrySendError::Rejected(_message)) => {
            // the message was rejected.
            // the channel will never accept this message.
        }
    }
}