Method all_pressed

src/timely-util/src/builder_async.rs:765–770

Returns whether all workers have pressed their buttons.

(&mut self)

    /// Returns whether all workers have pressed their buttons.
    pub fn all_pressed(&mut self) -> bool {
        while self.puller.recv().is_some() {
            self.buttons_remaining -= 1;
        }
        self.buttons_remaining == 0
    }
}

pub struct Button {