Struct TestScheduler 

pub struct TestScheduler { /* private fields */ }

Virtual-time scheduler. Time only advances when advance_by / advance_to is called.

Implementations

impl TestScheduler

pub fn new() -> Self

pub fn now(&self) -> Instant

Current virtual time.

pub fn schedule_after<F>(&self, delay: Duration, cb: F) -> ScheduledToken

where F: FnOnce() + Send + 'static,

Schedule cb to fire delay after the current virtual time.

pub fn cancel(&self, token: ScheduledToken) -> bool

Cancel a scheduled callback if it hasn’t fired or been cancelled yet. Returns true iff this call performed the cancellation; subsequent cancels of the same token are no-ops returning false.

pub async fn advance_by(&self, delta: Duration)

Advance virtual time by delta, firing all callbacks whose fire-at falls in the new range. Callbacks fire in fire-at order.

pub async fn advance_to(&self, target: Instant)

Advance virtual time to target (must be ≥ current time).

pub fn fired(&self, token: ScheduledToken) -> bool

Has the scheduled callback fired?

pub fn pending(&self) -> usize

How many scheduled entries are still pending (not fired, not cancelled)?

Trait Implementations

impl Clone for TestScheduler

fn clone(&self) -> TestScheduler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TestScheduler

fn default() -> Self

Returns the “default value” for a type.