Module mpsc

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

Execute

Type of future which Executor instances must be able to execute for spawn.

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.

SpawnHandle

Handle returned from the spawn function.

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.

spawn

Spawns a stream onto the instance of Executor provided, executor, returning a handle representing the remote stream.

spawn_unbounded

Spawns a stream onto the instance of Executor provided, executor, returning a handle representing the remote stream, with unbounded buffering.

unbounded

Creates an unbounded in-memory channel with buffered storage.