fn then<F, Fut>(self, f: F) -> Then<Self, F, Fut>
    where
        F: FnMut(Self::Item, &mut A, &mut A::Context) -> Fut,
        Fut: ActorFuture<A>,
        Self: Sized,
    {
        then::new(self, f)
    }
/// Computes from this stream's items new items of a different type using
/// an asynchronous closure.
///
/// The provided closure `f` will be called with an `Item` once a value is
/// ready, it returns a future which will then be run to completion
/// to produce the next value on this stream.
///
/// Note that this function consumes the stream passed into it and returns a
/// wrapped version of it.
Computes from this stream's items new items of a different type using
an asynchronous closure.

The provided closure `f` will be called with an `Item` once a value is
ready, it returns a future which will then be run to completion
to produce the next value on this stream.

Note that this function consumes the stream passed into it and returns a
wrapped version of it.
Computes from this stream ' s items new items of a different type using an asynchronous closure . The provided closure ` f ` will be called with an ` Item ` once a value is ready it returns a future which will then be run to completion to produce the next value on this stream . Note that this function consumes the stream passed into it and returns a wrapped version of it .
fn then<F, Fut>(self, f: F) -> Then<Self, F, Fut>
    where
        F: FnMut(Self::Item, &mut A, &mut A::Context) -> Fut,
        Fut: ActorFuture<A>,
        Self: Sized,
    {
        then::new(self, f)
    }
fn then < F , Fut > ( self , f : F ) -> Then < Self , F , Fut > where F : FnMut ( Self :: Item , & mut A , & mut A :: Context ) -> Fut , Fut : ActorFuture < A > , Self : Sized , { then :: new ( self , f ) }
Computes from this stream's items new items of a different type using
an asynchronous closure.
Computes from this stream ' s items new items of a different type using an asynchronous closure .
self
f
F
self
f
F