Struct WebSocketServer 

pub struct WebSocketServer { /* private fields */ }

WebSocket server - integrates with elif HTTP server

Implementations

impl WebSocketServer

pub fn new() -> Self

Create a new WebSocket server

pub fn with_config(config: WebSocketConfig) -> Self

Create with custom configuration

pub fn registry(&self) -> Arc<ConnectionRegistry>

Get the connection registry

pub async fn stats(&self) -> RegistryStats

Get server statistics

pub fn add_websocket_route<F, Fut>( &self, router: ElifRouter, path: &str, _handler: F, ) -> ElifRouter

where F: Fn(ConnectionId, Arc<WebSocketConnection>) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static,

Add a WebSocket route to the router using a simple closure For now, this is a placeholder that will be improved in later iterations

pub fn add_handler<F, Fut>( &self, router: ElifRouter, path: &str, handler: F, ) -> ElifRouter

where F: Fn(ConnectionId, Arc<WebSocketConnection>) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static,

Add a simple WebSocket handler function (alias for add_websocket_route)

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

Broadcast a message to all connections

pub async fn broadcast_text<T: Into<String>>(&self, text: T) -> BroadcastResult

Broadcast text to all connections

pub async fn broadcast_binary<T: Into<Vec<u8>>>( &self, data: T, ) -> BroadcastResult

Broadcast binary data to all connections

pub async fn send_to_connection( &self, id: ConnectionId, message: WebSocketMessage, ) -> WebSocketResult<()>

Send a message to a specific connection

pub async fn send_text_to_connection<T: Into<String>>( &self, id: ConnectionId, text: T, ) -> WebSocketResult<()>

Send text to a specific connection

pub async fn send_binary_to_connection<T: Into<Vec<u8>>>( &self, id: ConnectionId, data: T, ) -> WebSocketResult<()>

Send binary data to a specific connection

pub async fn get_connection_ids(&self) -> Vec<ConnectionId>

Get all active connection IDs

pub async fn connection_count(&self) -> usize

Get the number of active connections

pub async fn close_connection(&self, id: ConnectionId) -> WebSocketResult<()>

Close a specific connection

pub async fn close_all_connections(&self) -> CloseAllResult

Close all connections

pub fn start_cleanup_task(&mut self, interval_seconds: u64)

Start the cleanup task for inactive connections

pub fn stop_cleanup_task(&mut self)

Stop the cleanup task

Trait Implementations

impl Default for WebSocketServer

fn default() -> Self

Returns the “default value” for a type.

impl Drop for WebSocketServer

fn drop(&mut self)

Executes the destructor for this type.