Struct EventBus 

pub struct EventBus { /* private fields */ }

Implementations

impl EventBus

pub fn new() -> Self

pub fn subscribe(&self, event: &'static str, listener: Arc<dyn Listener>)

Register a listener. Control-plane operation (boot / plugin init): clones the listener table and swaps the snapshot — emitters in flight keep their consistent view, the next emit sees the new one.

pub async fn emit(&self, event: &'static str, payload: Value)

Fan an event out to every subscribed listener, concurrently. Hot-path cost: one atomic load + one hash probe. No locks.

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for EventBus

fn default() -> EventBus

Returns the “default value” for a type.