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§
- Receiver
- The receiver half of a dispatch channel.
- Sender
- The sender half of a dispatch channel. Can send messages with the
postage::Sink
trait.
Functions§
- channel
- Constructs a pair of dispatch endpoints, with a fixed-size buffer of the given capacity