Struct Runtime 

pub struct Runtime { /* private fields */ }

Runtime from the futures-executor crate

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CompatInterface for Runtime

Available on crate feature futures_runtime only.

fn tokio_compat<T>( f: impl Future<Output = T> + Send, ) -> impl Future<Output = T> + Send

Drive a future in a compatibility layer.

fn spawn_tokio_task<F, T>( &self, future: F, ) -> Result<TaskHandle<Self::TaskHandle<<F as Future>::Output>>, Self::SpawnError>

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Spawn a task using tokio compatibility layer.

impl CreationInterface for Runtime

type NewError = Error

Error type when creating

fn new( config: Config, ) -> Result<Runtime, <Runtime as CreationInterface>::NewError>

Create a new runtime

impl From<ThreadPool> for Runtime

fn from(thread_pool: ThreadPool) -> Runtime

Converts to this type from the input type.

impl TaskInterface for Runtime

type TaskHandle<T: 'static + Send> = RemoteHandle<Result<T, <Runtime as TaskInterface>::JoinError>>

Result of spawning a task

type SpawnError = SpawnError

Error type for errors occuring during spawning

type JoinError = Infallible

Error type when creating

fn spawn_task<F, T>( &self, future: F, ) -> Result<TaskHandle<<Runtime as TaskInterface>::TaskHandle<<F as Future>::Output>>, <Runtime as TaskInterface>::SpawnError>

where F: Future<Output = T> + Send + 'static, T: Send + 'static,

Spawn a task

fn block_on<F>(&self, future: F) -> <F as Future>::Output

where F: Future,

Block on task

impl TimeInterface for Runtime

Available on crate feature futures_runtime only.

type Elapsed = Elapsed

Error type for timeout.

async fn sleep(duration: Duration)

Sleep for the given duration.

fn timeout<T>( duration: Duration, future: impl Future<Output = T> + Send, ) -> impl Future<Output = Result<T, <Runtime as TimeInterface>::Elapsed>> + Send

Wait for the future to complete, return an error if the future does not complete before the given duration.