Struct WebsocketServer 

pub struct WebsocketServer { /* private fields */ }

The WebSocket server itself

Implementations

impl WebsocketServer

pub fn new( ip_address: String, port: String, cert_path: Option<String>, key_path: Option<String>, ) -> Self

Create a new WebSocket server instance

pub fn get_message_sender(&self) -> Sender<(String, WebSocketMessage)>

Get a clone of the message sender for sending messages to clients

pub fn take_message_receiver( &self, ) -> Option<Receiver<(String, WebSocketMessage)>>

Take the message receiver to process incoming messages

pub async fn start(&self) -> Receiver<(String, WebSocketMessage)>

Start the WebSocket server and return the message receiver for processing incoming messages

pub async fn send_to_client( &self, client_id: String, message: WebSocketMessage, ) -> Result<(), String>

Send a message to a specific client

pub async fn broadcast(&self, message: WebSocketMessage) -> Result<(), String>

Send a message to all connected clients

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

Get a list of all connected client IDs

Trait Implementations

impl Clone for WebsocketServer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.