Struct EventBus 

pub struct EventBus { /* private fields */ }

A simple in-app event bus for decoupling components.

Components emit events via EventBus::emit and the main loop drains the pending queue via EventBus::drain once per frame, forwarding them to PluginManager::process_events.

External code can register read-only observers with EventBus::subscribe to react to events without consuming them (e.g. event logging, metrics).

The pending queue is capped at [MAX_PENDING] entries. If full, the oldest event is dropped to make room for the newest, ensuring the bus never grows without bound.

Implementations

impl EventBus

pub fn new() -> Self

pub fn subscribe(&mut self, f: EventSubscriber)

Register a read-only observer that is called for every emitted event.

Subscribers are invoked synchronously inside EventBus::emit after the event is pushed to the pending queue. They receive a shared reference and cannot modify or consume the event.

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

Push an event onto the pending queue and notify all subscribers.

If the queue is at capacity the oldest event is dropped.

pub fn drain(&mut self) -> Vec<Event>

Drain all pending events.

Trait Implementations

impl Debug for EventBus

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

Formats the value using the given formatter.

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.