pub fn exhaust_map<TIn: Clone + 'static, TOut: 'static>( project: impl Fn(&TIn) -> Node<TOut> + 'static, ) -> Operator<TOut>
exhaust_map: project the first source DATA while no inner is live; ignore source DATA while busy.