risingwave_stream::executor

Function expect_first_barrier

source 
pub async fn expect_first_barrier<M: Debug>(
    stream: &mut (impl MessageStreamInner<M> + Unpin),
) -> StreamExecutorResult<BarrierInner<M>>
Expand description

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