pub fn unbounded<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>)
Expand description
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.