Function channel

pub fn channel<T>(
    size: usize,
    f: impl AsyncFnOnce(Sender<T>),
) -> impl Stream<Item = T>

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

This is a more ergonomic [stream::unfold], which allows you to go from the “world of futures” to the “world of streams” by simply looping and publishing to an async channel from inside a Future.