Struct reactor::Timer

pub struct Timer { /* private fields */ }

Manages timers and triggers timeouts.

Implementations

impl Timer

pub fn new() -> Self

Create a new timeout manager.

Takes a threshold below which two timeouts cannot overlap.

pub fn len(&self) -> usize

Return the number of timeouts being tracked.

pub fn is_empty(&self) -> bool

Check whether there are timeouts being tracked.

pub fn set_timer(&mut self, span: Duration, after: Timestamp)

Register a new timeout with an associated key and wake-up time from a UNIX time epoch.

pub fn next(&self, after: impl Into<Timestamp>) -> Option<Duration>

Get the minimum time duration we should wait for at least one timeout to be reached. Returns None if there are no timeouts.

use reactor::{Timer, Timestamp};

let mut tm = Timer::new();

let now = Timestamp::now();
tm.set_timer(Duration::from_secs(16), now);
tm.set_timer(Duration::from_secs(8), now);
tm.set_timer(Duration::from_secs(64), now);

let mut now = Timestamp::now();
// We need to wait 8 secs to trigger the next timeout (1).
assert!(tm.next(now) <= Some(Duration::from_secs(8)));

// ... sleep for a sec ...
now += Duration::from_secs(1);

// Now we don't need to wait as long!
assert!(tm.next(now).unwrap() <= Duration::from_secs(7));

pub fn expire(&mut self, time: Timestamp) -> usize

Returns vector of timers which has fired before certain time.

Trait Implementations

impl Debug for Timer

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

Formats the value using the given formatter.

impl Default for Timer

fn default() -> Timer

Returns the “default value” for a type.