Enum deadpool_redis::cluster::Runtime

pub enum Runtime {
    Tokio1,
    AsyncStd1,
}

Enumeration for picking a runtime implementation.

Variants

Tokio1

tokio 1.0 runtime.

AsyncStd1

async-std 1.0 runtime.

Implementations

impl Runtime

pub async fn timeout<F>( &self, duration: Duration, future: F ) -> Option<<F as Future>::Output>

where F: Future,

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

If the future completes before the duration has elapsed, then the completed value is returned. Otherwise, an error is returned and the future is canceled.

pub async fn spawn_blocking<F, R>(&self, f: F) -> Result<R, SpawnBlockingError>

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

Runs the given closure on a thread where blocking is acceptable.

Errors

See SpawnBlockingError for details.

pub fn spawn_blocking_background<F>( &self, f: F ) -> Result<(), SpawnBlockingError>

where F: FnOnce() + Send + 'static,

Runs the given closure on a thread where blocking is acceptable.

It works similar to Runtime::spawn_blocking() but doesn’t return a Future and is meant to be used for background tasks.

Errors

See SpawnBlockingError for details.

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Runtime

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

Formats the value using the given formatter.

impl PartialEq for Runtime

fn eq(&self, other: &Runtime) -> 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 Copy for Runtime

impl Eq for Runtime

impl StructuralPartialEq for Runtime