risingwave_stream::executor::temporal_join

Function chunks_until_barrier

Source 
fn chunks_until_barrier(
    stream: impl MessageStream,
    expected_barrier: Barrier,
) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>>