Struct TimerService 

pub struct TimerService { /* private fields */ }

Timer service for scheduling and managing timers.

The timer service maintains a priority queue of timer registrations, ordered by timestamp. Operators can register timers to be fired at specific event times.

Example

use laminar_core::time::{TimerService, TimerKey};

let mut service = TimerService::new();

// Register timers at different times
let id1 = service.register_timer(100, None, None);
let id2 = service.register_timer(50, Some(TimerKey::from_slice(&[1, 2, 3])), None);

// Poll for timers that should fire at time 75
let fired = service.poll_timers(75);
assert_eq!(fired.len(), 1);
assert_eq!(fired[0].id, id2); // Timer at t=50 fires first

Implementations

impl TimerService

pub fn new() -> Self

Creates a new timer service.

pub fn register_timer( &mut self, timestamp: i64, key: Option<TimerKey>, operator_index: Option<usize>, ) -> u64

Registers a new timer.

Returns the unique timer ID that can be used to cancel the timer.

Arguments

• timestamp - The event time at which the timer should fire
• key - Optional key for keyed operators
• operator_index - Optional index of the operator registering the timer(must match the index in the reactor)

pub fn poll_timers(&mut self, current_time: i64) -> FiredTimersVec

Polls for timers that should fire at or before the given timestamp.

Returns all timers with timestamps <= current_time, in order. Uses FiredTimersVec (SmallVec) to avoid heap allocation when few timers fire.

Panics

This function should not panic under normal circumstances. The internal expect is only called after verifying the heap is not empty via peek.

pub fn cancel_timer(&mut self, id: u64) -> bool

Cancels a timer by ID.

Returns true if the timer was found and cancelled.

pub fn pending_count(&self) -> usize

Returns the number of pending timers.

pub fn next_timer_timestamp(&self) -> Option<i64>

Returns the timestamp of the next timer to fire, if any.

pub fn clear(&mut self)

Clears all pending timers.

Trait Implementations

impl Default for TimerService

fn default() -> Self

Returns the “default value” for a type.