Struct EventBroadcasters 

pub struct EventBroadcasters { /* private fields */ }

Manage a collection of event channel senders for broadcasting agent events to multiple subscribers.

Stores Vec<mpsc::Sender<AgentEvent>> protected by a parking_lot::Mutex. broadcast() sends an event to all active subscribers and removes closed channels. subscribe() creates a new (EventSubscriber, CancelGuard) pair.

Implementations

impl EventBroadcasters

pub fn new() -> Self

pub fn broadcast(&self, event: &AgentEvent)

Send an event to all active subscribers.

Iterates all channel senders, attempting to send the event to each. Removes (and drops) senders whose receiver has been disconnected, keeping the list lean.

pub fn subscribe(&self) -> (EventSubscriber, CancelGuard)

Subscribe to events.

Creates a new channel and registers the sender. Returns an EventSubscriber (the receiver) and a CancelGuard that will automatically remove the sender when dropped.

Trait Implementations

impl Clone for EventBroadcasters

fn clone(&self) -> EventBroadcasters

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventBroadcasters

fn default() -> Self

Returns the “default value” for a type.