pub async fn wait_for_tasks_from_complete_to_drain(&self) {
        while !self.from_completions.is_empty() {
            self.task_taken_notifier.notified().await;
        }
    }
/// Returns a future which resolves when all tasks from completions have been taken
Returns a future which resolves when all tasks from completions have been taken
Returns a future which resolves when all tasks from completions have been taken
pub async fn wait_for_tasks_from_complete_to_drain(&self) {
        while !self.from_completions.is_empty() {
            self.task_taken_notifier.notified().await;
        }
    }
pub async fn wait_for_tasks_from_complete_to_drain ( & self ) { while ! self . from_completions . is_empty ( ) { self . task_taken_notifier . notified ( ) . await ; } }
Returns a future which resolves when all tasks from completions have been taken
Returns a future which resolves when all tasks from completions have been taken
&self
&self