Struct EventBus 

pub struct EventBus { /* private fields */ }

A fan-out event bus backed by a bounded broadcast channel.

Each subscriber receives an independent broadcast::Receiver to drain on its own task. Sending never blocks and no lock is held while receivers handle events. If a receiver falls behind its bounded buffer, Tokio’s broadcast channel reports a lag error to that receiver on its next receive.

Implementations

impl EventBus

pub const DEFAULT_CAPACITY: usize = 256

The default event buffer capacity.

pub fn new(capacity: usize) -> Self

Create a bus with the given bounded buffer capacity.

Tokio broadcast channels require a non-zero capacity, so a capacity of zero is treated as one.

pub fn new_default() -> Self

Create a bus with the default buffer capacity.

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

Subscribe to future events.

The caller owns the returned receiver and should drain it, typically on a dedicated task.

pub fn emit(&self, event: RunEvent) -> bool

Emit an event to all current subscribers.

Returns false when there are no active receivers. Sending is non-blocking; slow receivers observe broadcast::error::RecvError::Lagged when they next receive.

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() -> Self

Returns the “default value” for a type.

impl EventSink for EventBus

EventBus satisfies the core EventSink trait so it can be passed to run_agent via RunHooks.

fn emit(&self, event: RunEvent)

Emit event to all subscribers. Non-blocking; returns immediately.