risingwave_stream::executor::temporal_join

Function internal_messages_until_barrier

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