Struct Pumped 

pub struct Pumped { /* private fields */ }

An executor that runs nothing until its owner pumps it.

Jobs queue until run_pending; timers fire when advance moves the virtual clock past their deadline. Headless tests use it to make background completion deterministic, and a host that drives work from its own loop can install it and pump it there.

Implementations

impl Pumped

pub fn new() -> Pumped

A pumped executor whose virtual clock starts at the real current time.

pub fn starting_at(now: Instant) -> Pumped

pub fn background(&self) -> Background

pub fn run_pending(&self) -> usize

Run queued jobs, including any they queue, until none remain. Returns how many ran.

pub fn advance(&self, by: Duration)

Move the virtual clock forward by by, firing every timer that falls due in deadline order and running the work each one releases.

pub fn is_idle(&self) -> bool

Whether no job is queued. Armed timers do not count: a periodic refresh is always armed.

pub fn next_deadline(&self) -> Option<Instant>

The earliest armed timer, if any.

pub fn now(&self) -> Instant

The virtual clock.

Trait Implementations

impl Clone for Pumped

fn clone(&self) -> Pumped

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Pumped

fn default() -> Pumped

Returns the “default value” for a type.

impl Executor for Pumped

fn park(&self, deadline: Instant)

Runs queued work; with none queued, advances the virtual clock to the next timer or to deadline, whichever comes first.

fn spawn( &self, name: &'static str, job: Box<dyn FnOnce() + Send>, ) -> Result<(), Unsupported>

Run job off the calling thread. name identifies the work in logs.

fn wake_at(&self, deadline: Instant, wake: WakeHandle)

Call WakeHandle::wake on wake once now reaches deadline. A deadline already in the past wakes promptly.

fn now(&self) -> Instant

This executor’s clock. Deadlines passed to wake_at are measured against it.