Function scan 

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

scan: stateful accumulator, emitting each intermediate accumulator value.