Module stream

Expand description

Create asynchronous streams of data.

Functions§

channel
Creates a new [Stream] that produces the items sent from a Future to the [mpsc::Sender] provided to the closure.
try_channel
Creates a new [Stream] that produces the items sent from a Future that can fail to the [mpsc::Sender] provided to the closure.