risingwave_stream::executor::exchange::input

Function assert_equal_dispatcher_barrier

Source 
pub(crate) fn assert_equal_dispatcher_barrier<M1, M2>(
    first: &BarrierInner<M1>,
    second: &BarrierInner<M2>,
)