Function reduce 

pub fn reduce<S: 'static, T: Clone + 'static>(
    reducer: impl Fn(T, &S) -> T + 'static,
    seed: T,
) -> Operator<T>

reduce: accumulate the whole source and emit one final value on source COMPLETE.