Struct TokioRuntime 

pub struct TokioRuntime;

Tokio is the default asynchronous executor.

Trait Implementations

impl AsyncRuntime for TokioRuntime

type JoinError = JoinError

The error type of Self::JoinHandle.

type JoinHandle<T: OptionalSend + 'static> = JoinHandle<T>

The return type of Self::spawn.

type Sleep = Sleep

The type that enables the user to sleep in an asynchronous runtime.

type Instant = Instant

A measurement of a monotonically non-decreasing clock.

type TimeoutError = Elapsed

The timeout error type.

type Timeout<R, T: Future<Output = R> + OptionalSend> = Timeout<T>

The timeout type used by Self::timeout and Self::timeout_at that enables the user to await the outcome of a Future.

type ThreadLocalRng = ThreadRng

Type of a thread-local random number generator.

type OneshotSender<T: OptionalSend> = TokioOneShotSender<T>

Type of a oneshot sender.

type OneshotReceiver<T: OptionalSend> = Receiver<T>

Type of a oneshot receiver.

type OneshotReceiverError = RecvError

Type of a oneshot receiver error.

fn spawn<T>( future: T, ) -> <TokioRuntime as AsyncRuntime>::JoinHandle<<T as Future>::Output>

where T: Future + OptionalSend + 'static, <T as Future>::Output: OptionalSend + 'static,

Spawn a new task.

fn sleep(duration: Duration) -> <TokioRuntime as AsyncRuntime>::Sleep

Wait until duration has elapsed.

fn sleep_until( deadline: <TokioRuntime as AsyncRuntime>::Instant, ) -> <TokioRuntime as AsyncRuntime>::Sleep

Wait until deadline is reached.

fn timeout<R, F>( duration: Duration, future: F, ) -> <TokioRuntime as AsyncRuntime>::Timeout<R, F>

where F: Future<Output = R> + OptionalSend,

Require a Future to complete before the specified duration has elapsed.

fn timeout_at<R, F>( deadline: <TokioRuntime as AsyncRuntime>::Instant, future: F, ) -> <TokioRuntime as AsyncRuntime>::Timeout<R, F>

where F: Future<Output = R> + OptionalSend,

Require a Future to complete before the specified instant in time.

fn is_panic(join_error: &<TokioRuntime as AsyncRuntime>::JoinError) -> bool

Check if the Self::JoinError is panic.

fn thread_rng() -> <TokioRuntime as AsyncRuntime>::ThreadLocalRng

Get the random number generator to use for generating random numbers.

fn oneshot<T>() -> (<TokioRuntime as AsyncRuntime>::OneshotSender<T>, <TokioRuntime as AsyncRuntime>::OneshotReceiver<T>)

where T: OptionalSend,

Creates a new one-shot channel for sending single values.

impl Debug for TokioRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for TokioRuntime

fn default() -> TokioRuntime

Returns the “default value” for a type.

impl Eq for TokioRuntime

impl PartialEq for TokioRuntime

fn eq(&self, other: &TokioRuntime) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for TokioRuntime