/// Blocks until all futures associated with the tracker have been
/// dropped and no more can be created
Blocks until all futures associated with the tracker have been
dropped and no more can be created
Blocks until all futures associated with the tracker have been dropped and no more can be created
pub async fn join(&self) {
        // Notify is notified when pending_futures hits 0 AND when pending_registrations
        // hits 0. In almost all cases join won't be called before pending_registrations
        // has already hit 0, but in the extremely rare case this occurs the loop
        // handles the spurious wakeup
        loop {
            // Request notification before checking if complete
            // to avoid a race condition
            let notify = self.state.notify.notified();
            if self.is_complete() {
                return;
            }
            notify.await
        }
    }
pub async fn join ( & self ) { // Notify is notified when pending_futures hits 0 AND when pending_registrations // hits 0. In almost all cases join won't be called before pending_registrations // has already hit 0, but in the extremely rare case this occurs the loop // handles the spurious wakeup loop { // Request notification before checking if complete // to avoid a race condition let notify = self . state . notify . notified ( ) ; if self . is_complete ( ) { return ; } notify . await } }
Blocks until all futures associated with the tracker have been
dropped and no more can be created
Blocks until all futures associated with the tracker have been dropped and no more can be created
&self