Struct AsyncRuntime 

pub struct AsyncRuntime { /* private fields */ }

Manages the Tokio async runtime for a plugin

Implementations

impl AsyncRuntime

pub fn new(config: RuntimeConfig) -> PluginResult<Self>

Create a new async runtime with the given configuration

pub fn with_defaults() -> PluginResult<Self>

Create a runtime with default configuration

pub fn config(&self) -> &RuntimeConfig

Get the runtime configuration

pub fn handle(&self) -> Handle

Get a handle to the underlying Tokio runtime

pub fn shutdown_signal(&self) -> ShutdownSignal

Get a shutdown signal that can be used to detect shutdown

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

where F: Future,

Block on a future from a sync context

This is the primary method for bridging sync FFI calls to async handlers.

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 spawn_blocking<F, R>(&self, func: F) -> JoinHandle<R>

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

Spawn a blocking task

pub fn shutdown(&self, _timeout: Duration) -> PluginResult<()>

Initiate graceful shutdown

This signals all tasks to stop. The runtime will complete shutdown when dropped. We don’t unconditionally sleep for the timeout since most plugins have no long-running background tasks.

pub fn is_shutting_down(&self) -> bool

Check if shutdown has been triggered

Trait Implementations

impl Drop for AsyncRuntime

fn drop(&mut self)

Executes the destructor for this type.