Expand description
Create asynchronous streams of data.
Functions§
- Creates a new
Stream
that produces the items sent from aFuture
to thempsc::Sender
provided to the closure. - Creates a new
Stream
that produces the items sent from aFuture
that can fail to thempsc::Sender
provided to the closure.