Expand description

Module to define utility to drive a stream with an async function and a channel.

Structs§

  • The closure is passed a reference to a Sender which acts as a rendezvous channel. Messages sent to the sender will be emitted to the stream. Because the stream is 1-bounded, the function will not proceed until the stream is read.