MCPcopy Create free account
hub / github.com/comnik/declarative-dataflow / next

Method next

src/server/scheduler.rs:91–97  ·  view source on GitHub ↗
(&mut self)

Source from the content-addressed store, hash-verified

89impl Iterator for Scheduler {
90 type Item = TimedActivator;
91 fn next(&mut self) -> Option<TimedActivator> {
92 if self.has_pending() {
93 Some(self.activator_queue.pop().unwrap())
94 } else {
95 None
96 }
97 }
98}
99
100/// A set of things that we might want to schedule.

Callers 4

mainFunction · 0.45
mainFunction · 0.45
open_socketsFunction · 0.45
sourceMethod · 0.45

Calls 1

has_pendingMethod · 0.80

Tested by

no test coverage detected