Module mpsc 

A multi-producer, single-receiver channel.

This is an asynchronous, !Send version of std::sync::mpsc. Currently only the unbounded variant is implemented.

UnboundedReceiver implements [Stream] and allows asynchronous tasks to read values out of the channel. The UnboundedReceiver Stream will suspend and wait for available values if the current queue is empty. UnboundedSender implements [Sink] and allows messages to be sent to the corresponding UnboundedReceiver. The UnboundedReceiver also implements a send_now method to send a value synchronously.

Structs

SendError

Error returned by send_now.

TryRecvError

Error returned by try_next.

TrySendError

Error returned by UnboundedSender when used as a Sink.

UnboundedReceiver

The receiver of an unbounded mpsc channel.

UnboundedSender

The sender of an unbounded mpsc channel.

Functions

unbounded

Creates an unbounded channel.