Struct EventBus 

pub struct EventBus { /* private fields */ }

Fan-out event bus. Workers clone this and call emit() — events are delivered to all subscribers registered at build time.

Clone is cheap (Arc internals). All clones share the same subscriber list.

Implementations

impl EventBus

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

Emit an event to all subscribers. Lock-free read path — RwLock::read() never blocks other readers. Only close() takes a write lock (once, at shutdown).

pub fn close(&self)

Explicitly close all sender channels.

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.