Function try_channel

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

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