Trait stream_reduce::Reduce

pub trait Reduce<T>: Stream {
    fn reduce<F, Fut>(self, f: F) -> Reducer<Self, T, F, Fut>
    where
        Self: Sized,
        F: FnMut(T, Self::Item) -> Fut,
        Fut: Future<Output = T>,
    { ... }
}

Provided methods

fn reduce<F, Fut>(self, f: F) -> Reducer<Self, T, F, Fut> where
    Self: Sized,
    F: FnMut(T, Self::Item) -> Fut,
    Fut: Future<Output = T>, 

Loading content...

Implementors

impl<S, T> Reduce<T> for S where
    S: Stream<Item = T>, 

Loading content...