Struct EventBroadcaster 

pub struct EventBroadcaster { /* private fields */ }

EventBroadcaster implements EventSender. It holds a reference to the session map and queues events into per-session outboxes; the server loop drains the outboxes into the WebSocket while holding the session lock.

Events are NEVER written to the socket directly here: a command dispatch running inside CdpSession::process may emit events for that very session — taking the session lock here would self-deadlock the server loop. Outbox + drain-at-send-time preserves the domain gating (applied when the drain holds the session).

Implementations

impl EventBroadcaster

pub fn new(sessions: Arc<Mutex<HashMap<String, Arc<SessionHandle>>>>) -> Self

pub fn sender(&self) -> Box<dyn EventSender>

Create a boxed clone-safe EventSender reference.

Trait Implementations

impl Clone for EventBroadcaster

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EventSender for EventBroadcaster

fn send_session_event(&self, session_id: &str, method: &str, params: Value)

Session-scoped event (flattened CDP sessions): the event JSON carries sessionId, so clients route it to the attached target session. Delivered to browser-endpoint sessions (they own the flat sessions).

fn send_event(&self, method: &str, params: Value)

Broadcast an event to all sessions that have enabled the domain extracted from method (format: “Domain.eventName”).