datanode::heartbeat::task_tracker

Function wait

Source 
async fn wait<T: Send + Sync + Clone>(
    watcher: &mut Receiver<TaskState<T>>,
) -> Result<T>