Module websocket::async::futures::unsync::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.