Struct Environment 

pub struct Environment { /* private fields */ }

High-level container that owns one or more runtimes, exposes a unified event receiver, and provides lifecycle helpers for running and shutting down the underlying actor system.

Implementations

impl Environment

pub fn new(config: Option<EnvironmentConfig>) -> Self

Create a new environment with optional configuration.

pub async fn register_runtime( &mut self, runtime: Arc<dyn Runtime>, ) -> Result<(), Error>

Register a runtime with this environment and make it the default if none is set yet.

pub fn config(&self) -> &EnvironmentConfig

Access the environment configuration.

pub async fn get_runtime( &self, runtime_id: &RuntimeID, ) -> Option<Arc<dyn Runtime>>

Get a runtime by its id, if present.

pub async fn get_runtime_or_default( &self, runtime_id: Option<RuntimeID>, ) -> Result<Arc<dyn Runtime>, Error>

Get the specified runtime or the default one when None is passed.

pub fn run(&mut self) -> JoinHandle<Result<(), RuntimeError>>

Start all registered runtimes and return a handle that resolves when they finish. This will typically run until shutdown is requested.

pub async fn run_background(&mut self) -> Result<(), RuntimeError>

Start all registered runtimes and return immediately without waiting for completion.

pub async fn take_event_receiver( &mut self, runtime_id: Option<RuntimeID>, ) -> Result<BoxEventStream<Event>, EnvironmentError>

Take the event receiver for a specific runtime (or the default one) so the caller can consume protocol events. This can only be taken once.

pub async fn shutdown(&mut self)

Request shutdown on all runtimes and await the run handle if present.