Struct StepRuntime 

pub struct StepRuntime { /* private fields */ }

The test runtime handle: collects tasks for the pool and registers timers on the virtual clock.

Implementations

impl StepRuntime

pub fn new(clock: Arc<VirtualClock>) -> Arc<Self>

A runtime whose timers register on clock and whose tasks wait for a TestExecutor to drain them.

pub fn spawned(&self) -> u64

Tasks handed over so far, immediate and deferred.

Trait Implementations

impl Debug for StepRuntime

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

Formats the value using the given formatter.

impl Runtime for StepRuntime

fn spawn(&self, task: BoxFuture<'static, ()>)

Start task concurrently with the caller.

fn defer(&self, task: BoxFuture<'static, ()>)

Start task after work that is already runnable has progressed.

fn spawn_blocking( &self, task: Box<dyn FnOnce() + Send + 'static>, ) -> Result<(), BoxError>

Admit synchronous CPU work without blocking the async executor.

fn sleep(&self, duration: Duration) -> BoxFuture<'static, ()>

A timer that completes once duration has passed.