Struct sp_core::testing::TaskExecutor

pub struct TaskExecutor(_);

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.