risingwave_stream::executor::lookup::sides

Function poll_until_barrier

source 
pub fn poll_until_barrier(
    stream: impl MessageStream,
    expected_barrier: Barrier,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>