Function expect_first_barrier 

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

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