risingwave_stream::executor::backfill::snapshot_backfill

Function receive_next_barrier

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