Struct TaskExecutor

pub struct TaskExecutor(/* private fields */);

A task executor that can be used in tests.

Internally this just wraps a ThreadPool with a pool size of 8. This should ensure that we have enough threads in tests for spawning blocking futures.

Implementations

impl TaskExecutor

pub fn new() -> Self

Create a new instance of Self.

Trait Implementations

impl Clone for TaskExecutor

fn clone(&self) -> TaskExecutor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for TaskExecutor

fn default() -> Self

Returns the “default value” for a type.

impl SpawnEssentialNamed for TaskExecutor

fn spawn_essential_blocking( &self, _: &'static str, _: Option<&'static str>, future: BoxFuture<'static, ()>, )

Spawn the given blocking future.

fn spawn_essential( &self, _: &'static str, _: Option<&'static str>, future: BoxFuture<'static, ()>, )

Spawn the given non-blocking future.

impl SpawnNamed for TaskExecutor

fn spawn_blocking( &self, _name: &'static str, _group: Option<&'static str>, future: BoxFuture<'static, ()>, )

Spawn the given blocking future.

fn spawn( &self, _name: &'static str, _group: Option<&'static str>, future: BoxFuture<'static, ()>, )

Spawn the given non-blocking future.