Trait Executor 

pub trait Executor:
    Clone
    + Send
    + Sync
    + 'static {
    // Required methods
    fn spawn(
        &self,
        f: Pin<Box<dyn Future<Output = ()> + Send>>,
    ) -> Result<(), ()>;
    fn spawn_blocking<F, Res>(&self, f: F) -> JoinHandle<Res> 
       where F: FnOnce() -> Res + Send + 'static,
             Res: Send + 'static;
    fn interval(&self, duration: Duration) -> Interval;
    fn delay(&self, duration: Duration) -> Delay ;
    fn kind(&self) -> ExecutorKind;
}

Wrapper trait abstracting the Tokio and async-std executors

Required Methods

fn spawn(&self, f: Pin<Box<dyn Future<Output = ()> + Send>>) -> Result<(), ()>

spawns a new task

fn spawn_blocking<F, Res>(&self, f: F) -> JoinHandle<Res>

where F: FnOnce() -> Res + Send + 'static, Res: Send + 'static,

spawns a new blocking task

fn interval(&self, duration: Duration) -> Interval

returns a Stream that will produce at regular intervals

fn delay(&self, duration: Duration) -> Delay

waits for a configurable time

fn kind(&self) -> ExecutorKind

returns which executor is currently used

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<Exe: Executor> Executor for Arc<Exe>

fn spawn(&self, f: Pin<Box<dyn Future<Output = ()> + Send>>) -> Result<(), ()>

fn spawn_blocking<F, Res>(&self, f: F) -> JoinHandle<Res>

where F: FnOnce() -> Res + Send + 'static, Res: Send + 'static,

fn interval(&self, duration: Duration) -> Interval

fn delay(&self, duration: Duration) -> Delay

fn kind(&self) -> ExecutorKind

Implementors

impl Executor for AsyncStdExecutor

impl Executor for TokioExecutor