Check if there are pending continuations to dispatch.
(&self)
| 95 | |
| 96 | /// Check if there are pending continuations to dispatch. |
| 97 | pub fn has_pending(&self) -> bool { |
| 98 | !self.pending.is_empty() |
| 99 | } |
| 100 | |
| 101 | /// Take all pending continuations for a target shard. |
| 102 | pub fn take_pending(&mut self, shard_id: u32) -> Vec<PatternContinuation> { |