Struct OwnedRuntime 

pub struct OwnedRuntime { /* private fields */ }

Available on crate feature std only.

An owned Tokio runtime with an optional dial9 telemetry session.

This type centralizes runtime access for components that own their runtime. Use block_on_task and spawn for owned work that should participate in dial9 task tracking. The borrowed block_on variant exists for construction futures that cannot be 'static.

Implementations

impl OwnedRuntime

pub fn from_tokio(runtime: Runtime) -> OwnedRuntime

Wrap a Tokio runtime.

pub fn from_dial9(runtime: TracedRuntime) -> OwnedRuntime

Available on crate feature dial9 only.

Wrap a dial9 traced runtime and retain its telemetry guard.

pub fn handle(&self) -> OwnedRuntimeHandle

Return a cloneable handle targeting this runtime and telemetry session.

The handle does not keep this runtime alive.

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

Enter the underlying Tokio runtime on the calling thread.

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

where F: Future,

Run a possibly borrowed future to completion.

This directly drives Tokio and does not create a dial9-tracked task. Prefer block_on_task for owned work.

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

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

Run an owned future to completion as a task on this runtime.

With dial9 enabled, this routes through the runtime’s exact telemetry handle so wake tracking remains active. Rama protocol events that use dial9’s ambient handle require a multi-thread Tokio runtime.

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

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

Spawn an owned future on this runtime.

pub fn shutdown_bounded(self, grace: Duration)

Dispose of the runtime without blocking the caller indefinitely.

Tokio supports a bounded consuming shutdown directly. dial9’s traced runtime does not currently expose one, so its drop is isolated on a reaper thread and awaited for at most grace.

Trait Implementations

impl Debug for OwnedRuntime

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

Formats the value using the given formatter.