expect_first_barrier

risingwave_stream::executor::temporal_join

Function expect_first_barrier 

Source 
pub(super) async fn expect_first_barrier(
    stream: &mut (impl Stream<Item = StreamExecutorResult<InternalMessage>> + Unpin),
) -> StreamExecutorResult<Barrier>