risingwave_stream::executor::backfill::snapshot_backfill::utils

Function receive_next_barrier

Source 
pub(super) async fn receive_next_barrier(
    barrier_rx: &mut UnboundedReceiver<Barrier>,
) -> StreamExecutorResult<Barrier>