Struct AsyncRuntime 

pub struct AsyncRuntime { /* private fields */ }

Available on crate feature tokio-comp only.

FFI-safe async runtime wrapper

This struct wraps Tokio’s Runtime and provides safe methods for:

• Creating/destroying runtime across FFI boundary
• Spawning async tasks
• Blocking on futures
• Graceful shutdown

Implementations

impl AsyncRuntime

pub fn new() -> Result<Self, MarketDataError>

Create a new multi-threaded Tokio runtime

Errors

Returns RuntimeError if the runtime cannot be created

pub fn handle(&self) -> Handle

Get a handle to the runtime for spawning tasks

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

where F: Future,

Block on a future until it completes

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

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawn a task on the runtime

pub fn shutdown(self)

Shutdown the runtime gracefully