Trait stream_combinators::stream_sequence::SequenceStream

pub trait SequenceStream: Stream + Sized {
    fn sequence<F, U>(self, f: F) -> Sequence<Self, F, U>
    where
        F: FnOnce(Chain<Once<Self::Item, Self::Error>, Self>) -> U,
        U: Stream,
    { ... }
}

Provided Methods

fn sequence<F, U>(self, f: F) -> Sequence<Self, F, U> where
    F: FnOnce(Chain<Once<Self::Item, Self::Error>, Self>) -> U,
    U: Stream, 

Create a Sequence stream from a stream.

Takes a transformation function which will be applied to the stream immediately before it produces a value.

Implementors

• impl<S> SequenceStream for S where
    S: Stream,