Skip to main content

wait_collection

risingwave_meta::barrier::notifier

Function wait_collection 

Source 
pub(crate) async fn wait_collection(
    receivers: Vec<Receiver<MetaResult<()>>>,
) -> MetaResult<()>