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.
pub async fn expect_first_barrier_from_aligned_stream(
stream: &mut (impl AlignedMessageStream + Unpin),
) -> StreamExecutorResult<Barrier>Expect the first message of the given stream as a barrier.