Expand description
A fixed-capacity multi-producer, multi-consumer queue. At most one receiver will observe each value.
Senders and recievers can be cloned, and additional recievers can be created with tx.subscribe()
The producer can be cloned, and the sender task is suspended if the channel becomes full.
Structs
The receiver half of a dispatch channel.
The sender half of a dispatch channel. Can send messages with the postage::Sink trait.
Functions
Constructs a pair of dispatch endpoints, with a fixed-size buffer of the given capacity