Expand description
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
Type of future which Executor instances must be able to execute for spawn.
The receiving end of a channel which implements the Stream trait.
Error type for sending, used when the receiving end of a channel is dropped
The transmission end of a channel.
Handle returned from the spawn function.
The receiving end of an unbounded channel.
The transmission end of an unbounded channel.
Functions
Creates a bounded in-memory channel with buffered storage.
Spawns a stream onto the instance of Executor provided, executor,
returning a handle representing the remote stream.
Spawns a stream onto the instance of Executor provided, executor,
returning a handle representing the remote stream, with unbounded buffering.
Creates an unbounded in-memory channel with buffered storage.