Struct TimerPoller 

pub struct TimerPoller<S = Box<dyn Handler<Instant>>, Store = UnboundedSlab<WheelEntry<S>>> { /* private fields */ }

Timer driver poller — generic over handler storage and slab store.

Returned by TimerInstaller::install. Holds a pre-resolved ResourceId for the wheel and a reusable drain buffer.

Store is the slab backend — determines which TimerWheel<S, Store> resource to look up in the World. Defaults to the unbounded slab.

Implementations

impl<S, Store> TimerPoller<S, Store>

where S: DerefMut + Send + 'static, S::Target: Handler<Instant>, Store: SlabStore<Item = WheelEntry<S>> + 'static,

pub fn poll(&mut self, world: &mut World, now: Instant) -> usize

Poll expired timers — drain from wheel, fire each handler, done.

Each handler receives now as its event. Handlers that need to reschedule themselves do so directly via the wheel resource.

Returns the number of timers fired.

pub fn next_deadline(&self, world: &World) -> Option<Instant>

Earliest deadline in the wheel.

pub fn len(&self, world: &World) -> usize

Number of active timers.

pub fn is_empty(&self, world: &World) -> bool

Whether the wheel is empty.

Trait Implementations

impl<S, Store> Debug for TimerPoller<S, Store>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.