Struct WebSocketManager 

pub struct WebSocketManager { /* private fields */ }

Manages connected WebSocket clients for all active subscriptions.

Implementations

impl WebSocketManager

pub fn new() -> Self

Creates a new empty manager.

pub fn register_client( &self, tenant_id: &str, subscription_id: &str, ) -> (String, UnboundedReceiver<Value>)

Registers a new WebSocket client for a subscription.

Returns (client_id, receiver). The caller (WebSocket handler) reads notifications from the receiver and forwards them over the socket.

pub fn remove_client( &self, tenant_id: &str, subscription_id: &str, client_id: &str, )

Removes a specific client by ID (called on disconnect).

pub fn send_to_subscription( &self, tenant_id: &str, subscription_id: &str, notification: &Value, ) -> usize

Broadcasts a notification to all connected clients for a subscription.

Automatically prunes disconnected clients (closed channels). Returns the number of clients that received the message.

pub fn client_count(&self, tenant_id: &str, subscription_id: &str) -> usize

Returns the number of connected clients for a subscription.

pub fn remove_all_clients(&self, tenant_id: &str, subscription_id: &str)

Removes all clients for a subscription (called on deregistration).

Dropping the senders causes receivers to return None, which triggers graceful close in the WebSocket handlers.

Trait Implementations

impl Default for WebSocketManager

fn default() -> Self

Returns the “default value” for a type.