Struct AsyncRuntime 

pub struct AsyncRuntime { /* private fields */ }

A wrapper around a Tokio Runtime.

Provides convenient constructors for common configurations and exposes the most-used entry points (block_on, spawn, handle, enter).

Implementations

impl AsyncRuntime

pub fn new() -> Result<AsyncRuntime, CoreError>

Create a multi-threaded runtime with Tokio’s defaults (one worker thread per logical CPU, all feature flags enabled).

pub fn multi_thread(num_workers: usize) -> Result<AsyncRuntime, CoreError>

Create a multi-threaded runtime with an explicit worker-thread count.

pub fn current_thread() -> Result<AsyncRuntime, CoreError>

Create a single-threaded (current-thread) runtime.

pub fn handle(&self) -> Handle

Return a cloneable Handle to this runtime.

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

where F: Future,

Block the current thread until future completes and return its output.

pub fn spawn<F>(&self, future: F) -> JoinHandle<<F as Future>::Output>

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

Spawn a future onto the runtime without waiting for its result.

pub fn enter(&self) -> EnterGuard<'_>

Enter the runtime context so that async code can call Handle::current().