risingwave_stream::executor

Function expect_first_barrier_from_aligned_stream

source 
pub async fn expect_first_barrier_from_aligned_stream(
    stream: &mut (impl AlignedMessageStream + Unpin),
) -> StreamExecutorResult<Barrier>
Expand description

Expect the first message of the given stream as a barrier.