pub fn take_until<T: Clone + 'static>() -> Operator<T>
take_until: forward source values until notifier DATA arrives, then COMPLETE.