Trait stream_combinators::filter_fold::FilterFoldStream [−] [src]

pub trait FilterFoldStream: Stream + Sized {
    fn filter_fold<F, A, Fut, U>(
        self, 
        acc: A, 
        f: F
    ) -> FilterFold<Self, F, A, Fut>
    where
        Self::Error: From<Fut::Error>,
        F: FnMut(A, Self::Item) -> Fut,
        Fut: IntoFuture<Item = (A, Option<U>)>,
    { ... }
}

Provided Methods

Create a FilterFold stream from a stream.

Takes an inital accumulator value and an FnMut which takes two parameters, the current accumulator value and the current value from the stream, and returns a Future which resolves to a tuple where the first item is the new accumulator value and the second item is an Option. The FilterFold stream contains the values that are Some.

Implementors