Struct WebSocketServer 

pub struct WebSocketServer { /* private fields */ }

WebSocket server with connection management

Implementations

impl WebSocketServer

pub fn new(_config: Config) -> Self

Create a new WebSocket server

pub fn is_websocket_upgrade<B>(req: &Request<B>) -> bool

Check if request is a WebSocket upgrade request

pub fn handshake<B>(req: &Request<B>) -> Result<Response<Full<Bytes>>, Error>

Perform WebSocket handshake

pub async fn add_connection( &self, id: String, sender: UnboundedSender<WebSocketMessage>, )

Add a new WebSocket connection

pub async fn remove_connection(&self, id: &str)

Remove a WebSocket connection

pub async fn broadcast(&self, message: WebSocketMessage)

Broadcast a message to all connected clients

pub async fn send_to( &self, id: &str, message: WebSocketMessage, ) -> Result<(), Error>

Send a message to a specific connection

pub async fn connection_count(&self) -> usize

Get the number of active connections

pub async fn list_connections(&self) -> Vec<String>

Get a list of all active connections

pub fn handle_message( &self, message: Message, ) -> Result<Option<WebSocketMessage>, Error>

Handle incoming WebSocket message

pub fn to_tungstenite_message(&self, message: &WebSocketMessage) -> Message

Convert WebSocket message to tungstenite message