Trait ExecutorTimeout 

pub trait ExecutorTimeout: Executor {
    // Provided methods
    fn spawn_timeout<F>(
        &self,
        duration: Duration,
        f: F,
    ) -> JoinHandle<Result<F::Output, TimeoutError>> 
       where F: Future + Send + 'static,
             F::Output: Send + 'static { ... }
    fn spawn_delay<F>(&self, duration: Duration, f: F) -> JoinHandle<F::Output> 
       where F: Future + Send + 'static,
             F::Output: Send + 'static { ... }
    fn spawn_abortable_timeout<F>(
        &self,
        duration: Duration,
        f: F,
    ) -> AbortableJoinHandle<Result<F::Output, TimeoutError>> 
       where F: Future + Send + 'static,
             F::Output: Send + 'static { ... }
    fn spawn_abortable_delay<F>(
        &self,
        duration: Duration,
        f: F,
    ) -> AbortableJoinHandle<F::Output> 
       where F: Future + Send + 'static,
             F::Output: Send + 'static { ... }
}

Provided Methods

fn spawn_timeout<F>( &self, duration: Duration, f: F, ) -> JoinHandle<Result<F::Output, TimeoutError>>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns a new asynchronous task in the background that must complete within duration, returning a JoinHandle.

If the future does not finish before duration elapses, it is dropped and the task completes with TimeoutError.

fn spawn_delay<F>(&self, duration: Duration, f: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns a task after waiting for a duration before the task is polled.

fn spawn_abortable_timeout<F>( &self, duration: Duration, f: F, ) -> AbortableJoinHandle<Result<F::Output, TimeoutError>>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns a new asynchronous task in the background that must complete within duration, returning an abortable handle that will cancel the task once the handle is dropped.

If the future does not finish before duration elapses, it is dropped and the task completes with TimeoutError.

fn spawn_abortable_delay<F>( &self, duration: Duration, f: F, ) -> AbortableJoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns an abortable task after waiting for duration before the task is polled.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<E> ExecutorTimeout for Arc<E>

where E: ExecutorTimeout,

fn spawn_timeout<F>( &self, duration: Duration, f: F, ) -> JoinHandle<Result<F::Output, TimeoutError>>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_delay<F>(&self, duration: Duration, f: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_abortable_timeout<F>( &self, duration: Duration, f: F, ) -> AbortableJoinHandle<Result<F::Output, TimeoutError>>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_abortable_delay<F>( &self, duration: Duration, f: F, ) -> AbortableJoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

impl<E> ExecutorTimeout for Rc<E>

where E: ExecutorTimeout,

fn spawn_timeout<F>( &self, duration: Duration, f: F, ) -> JoinHandle<Result<F::Output, TimeoutError>>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_delay<F>(&self, duration: Duration, f: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_abortable_timeout<F>( &self, duration: Duration, f: F, ) -> AbortableJoinHandle<Result<F::Output, TimeoutError>>

where F: Future + Send + 'static, F::Output: Send + 'static,

fn spawn_abortable_delay<F>( &self, duration: Duration, f: F, ) -> AbortableJoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Implementors

impl ExecutorTimeout for BuiltinExecutor

impl ExecutorTimeout for DummyExecutor

impl ExecutorTimeout for LiteExecutor

impl ExecutorTimeout for LiteRuntimeExecutor

impl ExecutorTimeout for TokioExecutor

impl ExecutorTimeout for TokioRuntimeExecutor

impl<E: ExecutorTimeout> ExecutorTimeout for ConfiguredExecutor<E>

impl<E: ExecutorTimeout> ExecutorTimeout for TrackerExecutor<E>

impl<E> ExecutorTimeout for ScopeExecutor<'_, E>

where E: Executor,