pub fn on_first_data<S: Clone + 'static>( f: impl Fn(&S) + 'static, ) -> Operator<S>
on_first_data: run a side-effect exactly once, then pass all values through.