pub async fn wait_for_all( wait_specs: Vec<WaitSpec>, collected_data: CollectedDataContainer, ) -> Result<()>