Method all

interactive_engine/executor/engine/pegasus/pegasus/src/progress.rs:84–86

(peers: u32)

    }

    pub fn all(peers: u32) -> Self {
        DynPeers { mask: PeerSet::All(peers) }
    }

    pub fn add_source(&mut self, worker: u32) {
        let mask = std::mem::replace(&mut self.mask, PeerSet::None);