pub fn concat_map<TIn: Clone + 'static, TOut: 'static>( project: impl Fn(&TIn) -> Node<TOut> + 'static, ) -> Operator<TOut>
concat_map: queue source values and run one projected inner at a time.