Struct openraft::async_runtime::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) -> Self::JoinHandle<T::Output>

where T: Future + OptionalSend + 'static, T::Output: OptionalSend + 'static,

Spawn a new task.

fn sleep(duration: Duration) -> Self::Sleep

Wait until duration has elapsed.

fn sleep_until(deadline: Self::Instant) -> Self::Sleep

Wait until deadline is reached.

fn timeout<R, F: Future<Output = R> + OptionalSend>( duration: Duration, future: F ) -> Self::Timeout<R, F>

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

fn timeout_at<R, F: Future<Output = R> + OptionalSend>( deadline: Self::Instant, future: F ) -> Self::Timeout<R, F>

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

fn is_panic(join_error: &Self::JoinError) -> bool

Check if the Self::JoinError is panic.

fn thread_rng() -> Self::ThreadLocalRng

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

fn oneshot<T>() -> (Self::OneshotSender<T>, Self::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

Formats the value using the given formatter.

impl Default for TokioRuntime

fn default() -> TokioRuntime

Returns the “default value” for a type.

impl PartialEq for TokioRuntime

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl Eq for TokioRuntime

impl StructuralPartialEq for TokioRuntime