pub fn make_stream<'a, T, I, F>(init: I) -> AsyncStream<'a, AsyncStreamFn<I, T, F>>
where
    I: FnOnce(AsyncStreamScope<'a, T>) -> F + 'a,
    F: Future<Output = ()> + 'a,
{
    AsyncStreamFn(init, PhantomData).into()
}
/// Construct a new [`AsyncStream`] from a generator function.
Construct a new [`AsyncStream`] from a generator function.
Construct a new [ ` AsyncStream ` ] from a generator function .
pub fn make_stream<'a, T, I, F>(init: I) -> AsyncStream<'a, AsyncStreamFn<I, T, F>>
where
    I: FnOnce(AsyncStreamScope<'a, T>) -> F + 'a,
    F: Future<Output = ()> + 'a,
{
    AsyncStreamFn(init, PhantomData).into()
}
pub fn make_stream < ' a , T , I , F > ( init : I ) -> AsyncStream < ' a , AsyncStreamFn < I , T , F > > where I : FnOnce ( AsyncStreamScope < ' a , T > ) -> F + ' a , F : Future < Output = ( ) > + ' a , { AsyncStreamFn ( init , PhantomData ) . into ( ) }
Construct a new [`AsyncStream`] from a generator function.
Construct a new [ ` AsyncStream ` ] from a generator function .
init
I
init
I