Module flume::async

source · []
Expand description

Futures and other types that allow asynchronous interaction with channels.

Structs

A future which allows asynchronously receiving a message.

A stream which allows asynchronously receiving messages.

A future that sends a value into a channel.

A sink that allows sending values into a channel.