Struct TimeQ

pub struct TimeQ<const SLOTS: usize = 4> { /* private fields */ }

A time ordered queue of Messages

Implementations

impl<const SLOTS: usize> TimeQ<SLOTS>

pub fn new(tick_resolution: Duration) -> Self

pub fn clear(&mut self)

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn tick_resolution(&self) -> Duration

pub fn insert(&mut self, message: Message) -> Result<(), Message>

Insert a message. If it is due immediately, Err(message) will be returned.

pub fn cancel(&mut self, message: &Message) -> bool

Cancel/remove the currently scheduled entry for a given message, returning true if the message was scheduled, or false otherwise

pub fn contains(&self, message: &Message) -> bool

pub fn pop(&mut self) -> MessageList

Pop all messages that are due now

pub fn drain(&mut self) -> impl Iterator<Item = Message> + use<'_, SLOTS>

Drain the entire contents of the timerwheel

pub fn retain<KEEPER>(&mut self, keeper: KEEPER)

where KEEPER: FnMut(&Message) -> bool,

Iterate the entire timeq and apply KEEPER to each item. If it returns true then the item will be retained in the timeq, otherwise, it will be unlinked from the timeq.

Trait Implementations

impl<const SLOTS: usize> Debug for TimeQ<SLOTS>

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

Formats the value using the given formatter.