Struct TokioRuntime 

pub struct TokioRuntime { /* private fields */ }

Spawns onto one tokio runtime, captured as a handle at construction, and uses that runtime’s timers.

The default instance is TokioRuntime::current, taken while the cache is built; DialCacheBuilder::build fails with a configuration error outside a tokio context instead of panicking on first use. The runtime must have its time driver enabled (tokio’s enable_time or enable_all), or the first deadline panics inside the detached work and surfaces as Error::Panic.

Implementations

impl TokioRuntime

pub fn current() -> Result<Self, ConfigError>

The runtime of the current tokio context.

pub fn from_handle(handle: Handle) -> Self

Use the runtime behind handle, whichever context later calls the cache.

Trait Implementations

impl Clone for TokioRuntime

fn clone(&self) -> TokioRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TokioRuntime

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

Formats the value using the given formatter.

impl Runtime for TokioRuntime

Available on crate feature tokio only.

fn spawn(&self, task: BoxFuture<'static, ()>)

Start task concurrently with the caller.

fn sleep(&self, duration: Duration) -> BoxFuture<'static, ()>

A timer that completes once duration has passed.

fn defer(&self, task: BoxFuture<'static, ()>)

Start task after work that is already runnable has progressed.

fn spawn_blocking( &self, task: Box<dyn FnOnce() + Send + 'static>, ) -> Result<(), BoxError>

Admit synchronous CPU work without blocking the async executor.