pub fn tap<S: Clone + 'static>(f: impl Fn(&S) + 'static) -> Operator<S>
tap: run a side-effect for each DATA occurrence and pass values through unchanged.