risingwave_stream::executor::exchange::input

Function process_dispatcher_msg

source 
pub(crate) async fn process_dispatcher_msg(
    dispatcher_msg: DispatcherMessage,
    barrier_rx: &mut UnboundedReceiver<Barrier>,
) -> StreamExecutorResult<Message>