Function flume::bounded

pub fn bounded<T>(n: usize) -> (Sender<T>, Receiver<T>)

Create a new channel with an upper bound.

Create an bounded channel with a Sender and Receiver connected to each end respectively. Values sent in one end of the channel will be received on the other end. The channel is thread-safe, and both sender and receiver may be sent to threads as necessary. In addition, Sender may be cloned. If there is no space left for new messages, calls to Sender::send will block (unblocking once a receiver has made space).

Examples

let (tx, rx) = flume::bounded(32);

tx.send(42).unwrap();
assert_eq!(rx.recv().unwrap(), 42);