pub fn take_while<S: Clone + 'static>( pred: impl Fn(&S) -> bool + 'static, ) -> Operator<S>
take_while: emit while pred holds; first failed value completes without emission.
pred