Module futures::unsync::mpsc [] [src]

A multi-producer, single-consumer, futures-aware, FIFO queue with back pressure, for use communicating between tasks on the same thread.

These queues are the same as those in futures::sync, except they're not intended to be sent across threads.

Structs

Receiver

The receiving end of a channel which implements the Stream trait.

SendError

Error type for sending, used when the receiving end of a channel is dropped

Sender

The transmission end of a channel.

UnboundedReceiver

The receiving end of an unbounded channel.

UnboundedSender

The transmission end of an unbounded channel.

Functions

channel

Creates a bounded in-memory channel with buffered storage.

unbounded

Creates an unbounded in-memory channel with buffered storage.