Method take_all_pending

nodedb-cluster/src/distributed_graph/pattern_match.rs:107–109

Take all pending continuations, grouped by target shard.

(&mut self)

    /// Take all pending continuations, grouped by target shard.
    pub fn take_all_pending(&mut self) -> HashMap<u32, Vec<PatternContinuation>> {
        std::mem::take(&mut self.pending)
    }

    /// Advance to next round. Returns `false` if max rounds reached.
    pub fn advance(&mut self) -> bool {