[−][src]Function ndless_async::mpsc::channel
pub fn channel<T>(buffer: usize) -> (Sender<T>, Receiver<T>)
Creates a bounded mpsc channel for communicating between asynchronous tasks.
Being bounded, this channel provides backpressure to ensure that the sender
outpaces the receiver by only a limited amount. The channel's capacity is
equal to buffer
. In other words, there are
buffer
"first come, first serve" slots available to all senders.
The Receiver
returned implements the
Stream
trait, while Sender
has its own method, send
.