Struct EventBus 

pub struct EventBus {
    watches: Mutex<HashMap<String, WindowWatchData>>,
}

Global event bus for dispatching WebSocket events to connected clients.

Fields

watches: Mutex<HashMap<String, WindowWatchData>>

Implementations

impl EventBus

pub fn new() -> Self

pub fn register_ws(&self, conn_id: &str, tab_id: &str) -> WsReceivers

Register a WebSocket connection for receiving events. Returns the priority + background receiver pair for the connection.

pub fn unregister_ws(&self, conn_id: &str)

Unregister a WebSocket connection.

pub fn has_connections_for(&self, tab_id: &str) -> bool

Check if any connections exist for a given window/tab ID.

pub async fn wait_for_connection(&self, tab_id: &str, timeout: Duration) -> bool

Wait for a connection to appear for the given tab_id (with timeout).

pub fn send_to_conn(&self, conn_id: &str, event: &WSEventType)

Send an event to a single connection by conn_id, on the priority lane. No-op if not found.

pub fn send_to_conn_lane(&self, conn_id: &str, event: &WSEventType, lane: Lane)

Send an event to a single connection by conn_id on a specific lane. No-op if not found.

pub fn broadcast_event(&self, event: &WSEventType)

Broadcast an event to all connected WebSocket clients, on the priority lane.

pub fn broadcast_event_lane(&self, event: &WSEventType, lane: Lane)

Broadcast an event to all connected WebSocket clients on a specific lane.

pub fn send_to_tab(&self, tab_id: &str, event: &WSEventType)

Send an event to connections matching a specific tab_id.

pub fn connection_count(&self) -> usize

Get the number of active connections.

Trait Implementations

impl Default for EventBus

fn default() -> Self

Returns the “default value” for a type.