[−][src]Crate flume
Flume
A blazingly fast multi-producer, single-consumer channel.
"Do not communicate by sharing memory; instead, share memory by communicating."
Examples
let (tx, rx) = flume::channel::<u32>(); tx.send(42).unwrap(); assert_eq!(rx.recv().unwrap(), 42);
Structs
IntoIter | An owned iterator over the items received from a channel. |
Iter | An iterator over the items received from a channel. |
Receiver | The receiving end of a channel. |
SendError | An error that may be emitted when attempting to send a value into a channel on a sender. |
Sender | A transmitting end of a channel. |
TryIter | An non-blocking iterator over the items received from a channel. |
Enums
RecvError | An error that may be emitted when attempting to wait for a value on a receiver. |
RecvTimeoutError | An error that may be emitted when attempting to wait for a value on a receiver with a timeout. |
TryRecvError | An error that may be emitted when attempting to fetch a value on a receiver. |
Functions
channel | Create a new channel. |