Struct Runtime 

pub struct Runtime<S> { /* private fields */ }

Runtime task manager for runnable providers.

This keeps JoinSet orchestration out of bootstrap and ensures shutdown is observed immediately via the shared shutdown token.

Implementations

impl<S> Runtime<S>

where S: Clone + Send + 'static,

pub fn spawn_all(&mut self, registry: &Registry<S>, state: S) -> usize

Spawn all runnable providers from registry.

impl<S> Runtime<S>

where S: SharedState,

pub async fn wait_until_shutdown(&mut self, state: &S) -> Result<()>

Run until shutdown is initiated or a critical runnable failure occurs.

Returns:

• Ok(()) when the shutdown token is cancelled or all runnables finished.
• Err(_) on critical startup/join failures.

impl<S> Runtime<S>

pub async fn abort_and_drain(&mut self)

Abort and drain all remaining runnable tasks.

pub async fn drain(&mut self) -> Result<()>

Wait for all remaining runnable tasks to finish on their own.

Shutdown-aware listeners do their protocol-level graceful drain inside their runnable future. The bootstrap layer must give those futures a chance to complete before falling back to abort_and_drain.

Trait Implementations

impl<S> Default for Runtime<S>

fn default() -> Self

Returns the “default value” for a type.