Struct WebSocketManager 

pub struct WebSocketManager { /* private fields */ }

WebSocket connection manager

Implementations

impl WebSocketManager

pub fn new() -> Self

pub async fn add_client( &self, client_id: String, sender: UnboundedSender<String>, )

pub async fn remove_client(&self, client_id: &str)

pub async fn broadcast_message( &self, message: WebSocketMessage, ) -> RragResult<()>

pub async fn get_client_count(&self) -> usize

pub fn subscribe_to_broadcasts(&self) -> Receiver<WebSocketMessage>