Trait Reduce

pub trait Reduce<T>: Stream {
    // Provided method
    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>,

Implementors

impl<S, T> Reduce<T> for S

where S: Stream<Item = T>,