[][src]Function suspend_channel::make_stream

pub fn make_stream<'a, T, I, F>(init: I) -> AsyncStream<'a, T, I, F> where
    I: FnOnce(AsyncStreamScope<'a, T>) -> F + 'a,
    F: Future<Output = ()> + 'a, 

Construct a new AsyncStream from a generator function.