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, ) -> UnboundedReceiver<Value>

Register a WebSocket connection for receiving events. Returns a receiver channel 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 broadcast_event(&self, event: &WSEventType)

Send an event to all connected WebSocket clients.

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.