Struct CurrentThreadExecutor

pub struct CurrentThreadExecutor<'a> { /* private fields */ }

An Executor that doesn’t spawn new threads, just runs on the current thread.

Implementations

impl<'a> CurrentThreadExecutor<'a>

pub fn new() -> Self

Create a new CurrentThreadExecutor

pub fn submit<T: 'a, F: Future<Output = T> + 'a>( &mut self, fut: F, ) -> LocalTaskHandle<T>

Submit a new task to this executor. Note: This does not immediately run the task, you still need to call either CurrentThreadExecutor::run_some or CurrentThreadExecutor::run_until_complete

pub fn run_some(&mut self)

Runs a single loop through the processing queue, in order, letting each task attempt to do work.

pub fn run_until_complete(&mut self)

Runs this executor until all submitted tasks are complete.

Trait Implementations

impl<'a> Default for CurrentThreadExecutor<'a>

fn default() -> CurrentThreadExecutor<'a>

Returns the “default value” for a type.