Function futures::sync::mpsc::unbounded

pub fn unbounded<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>)

Creates an in-memory channel implementation of the Stream trait with unbounded capacity.

This method creates a concrete implementation of the Stream trait which can be used to send values across threads in a streaming fashion. A send on this channel will always succeed as long as the receive half has not been closed. If the receiver falls behind, messages will be buffered internally.

Note that the amount of available system memory is an implicit bound to the channel. Using an unbounded channel has the ability of causing the process to run out of memory. In this case, the process will be aborted.