Lib.rs

postage::broadcast

广播通道在多个发送者和多个接收者之间提供可靠的广播传递。该通道具有固定容量，当缓冲区填满时，发送者将被挂起。

当克隆接收者时，两个接收者将接收到相同的消息序列。

发送者还提供了一个 subscribe() 方法，该方法创建一个接收器，该接收器将观察在调用 subscribe 之后发送的所有消息。

postage::dispatch

分发通道提供多发送者、多接收者的消息分发。一条消息最多只能被一个接收者观察到。该通道具有固定容量，当缓冲区填满时，发送者将被挂起。

可以使用 rx.clone() 或 tx.subscribe() 来创建接收器。

postage::mpsc

Postage 包含一个固定容量的多生产者、单消费者通道。生产者可以被克隆，当通道填满时，发送任务将被挂起。

postage::oneshot

Oneshot 通道在发送者和接收者之间传输单个值。两者都不能被克隆。如果发送者失败，接收者将收到一个 None 值。

postage::watch

Watch 通道可以用来异步传输状态。当创建接收器时，它们将立即收到一个初始值。它们还将收到新值，但不保证收到 每个 值。

通过 watch 通道传输的值必须实现 Default。实现这一点的一种简单方法是传输 Option<T>。

基准测试

postage 通道的基准测试，以及与之相当的 async-std/tokio 通道。

• send/recv 测量发送和接收一个项目所需的总时间。
• send full 测量发送一个项目并在满通道上获得 Poll::Pending 值所需的时间。
• recv empty 测量在空通道上获取 Poll::Pending 值所需的时间。

所有基准测试都是使用 criterion 进行的，位于 benches 目录中。