Struct LoopScheduler 

pub struct LoopScheduler { /* private fields */ }

Ticks registered loops on their cadence.

Implementations

impl LoopScheduler

pub fn new() -> Self

pub fn with_tick(self, d: Duration) -> Self

How often the scheduler wakes to check for due loops. A loop never fires more often than this, regardless of its cadence.

pub fn with_sink(self, s: Arc<dyn LoopSink>) -> Self

pub fn register(self, engine: LoopEngine) -> Self

Register a loop. Its spec().cadence is parsed into a schedule; an unparseable cadence is rejected so the problem surfaces at wiring time rather than silently never firing.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub async fn tick_once(&mut self) -> usize

Run every currently-due loop once. Returns how many fired. Best effort: one loop’s failure never stops the others (the engine itself never returns Err).

pub fn spawn(self)

Spawn the tick loop on a dedicated thread with its own single-threaded Tokio runtime. Runs forever.

Trait Implementations

impl Default for LoopScheduler

fn default() -> Self

Returns the “default value” for a type.