Struct tor_rtmock::task::MockExecutor

pub struct MockExecutor { /* private fields */ }

Executor for running tests with mocked environment

For test cases which don’t actually wait for anything in the real world.

This is the executor. It implements [Spawn] and BlockOn

It will usually be used as part of a MockRuntime.

Restricted environment

Tests run with this executor must not attempt to block on anything “outside”: every future that anything awaits must (eventually) be woken directly by some other task in the same test case.

(By directly we mean that the Waker::wake call is made by that waking future, before that future itself awaits anything.)

Panics

This executor will malfunction or panic if reentered.

Implementations

impl MockExecutor

pub fn new() -> Self

Make a MockExecutor with default parameters

pub fn with_scheduling(scheduling: SchedulingPolicy) -> Self

Make a MockExecutor with a specific SchedulingPolicy

impl MockExecutor

pub fn spawn_identified( &self, desc: impl Display, fut: impl Future<Output = ()> + Send + 'static ) -> impl Debug + Clone + Send + 'static

Spawn a task and return something to identify it

desc should Display as some kind of short string (ideally without spaces) and will be used in the Debug impl and trace log messages from MockExecutor.

The returned value is an opaque task identifier which is very cheap to clone and which can be used by the caller in debug logging, if it’s desired to correlate with the debug output from MockExecutor. Most callers will want to ignore it.

This method is infalliable. (The MockExecutor cannot be shut down.)

impl MockExecutor

pub fn progress_until_stalled(&self) -> impl Future<Output = ()>

Run tasks in the current executor until every other task is waiting

Panics

Might malfunction or panic if more than one such call is running at once.

(Ie, you must .await or drop the returned Future before calling this method again.)

Must be called and awaited within a future being run by self.

Trait Implementations

impl BlockOn for MockExecutor

fn block_on<F>(&self, fut: F) -> F::Outputwhere F: Future,

Run fut to completion, synchronously

Panics

Might malfunction or panic if:

• The provided future doesn’t complete (without externally blocking), but instead waits for something.

• The MockExecutor is reentered. (Eg, block_on is reentered.)

impl Clone for MockExecutor

fn clone(&self) -> MockExecutor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MockExecutor

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

Formats the value using the given formatter.

impl Default for MockExecutor

fn default() -> MockExecutor

Returns the “default value” for a type.

impl Spawn for MockExecutor

fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError>

Spawns a future that will be run to completion.

fn status(&self) -> Result<(), SpawnError>

Determines whether the executor is able to spawn new tasks.