Struct EventBus 

pub struct EventBus { /* private fields */ }

Central event bus used by the engine to publish lifecycle events.

Internally uses a tokio::sync::broadcast channel so that multiple independent async receivers can each consume every event.

Implementations

impl EventBus

pub fn new() -> Self

Create a new EventBus with an empty subscriber list.

pub fn subscribe(&self) -> Receiver<Event>

Subscribe to the broadcast channel and receive a Receiver handle. Multiple handles can be created; each will receive every future event.

pub async fn emit(&self, event: Event)

Emit an event to all broadcast receivers and all registered subscribers. If there are no broadcast receivers, the send is silently dropped.

pub fn add_subscriber( &mut self, subscriber: Box<dyn EventSubscriber + Send + Sync>, )

Register a synchronous subscriber that will be called for every event.

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.