Struct WebsocketServer 

pub struct WebsocketServer { /* private fields */ }

Implementations

impl WebsocketServer

pub fn new() -> Self

pub async fn start(&mut self, url: Option<String>) -> Result<()>

pub fn take_recv_channel(&mut self) -> Option<Receiver<InboundMessage>>

pub fn get_send_channel(&self) -> Sender<OutboundMessage>

pub async fn send_socket_message( &self, socket_message: SocketMessage, destination: OutboundMessageDestination, ) -> Result<(), WebsocketServerError>

pub fn send_outbound_message( &self, msg: OutboundMessage, ) -> Result<(), WebsocketServerError>

pub async fn clear_pending_reliable_message( pending_reliable_messages: Arc<RwLock<HashMap<String, OutboundMessage>>>, message_uuid: String, )

pub async fn try_send_outbound_messages( clients_map: Arc<RwLock<HashMap<String, ClientConnection>>>, rooms_map: Arc<RwLock<HashMap<String, HashSet<String>>>>, global_send_rx: Receiver<OutboundMessage>, ) -> Result<()>

pub async fn add_client_to_room( &self, client_connection_uuid: String, room_name: String, )

pub async fn remove_client_from_room( &self, client_connection_uuid: String, room_name: String, )

pub async fn broadcast( clients_map: Arc<RwLock<HashMap<String, ClientConnection>>>, rooms_map: Arc<RwLock<HashMap<String, HashSet<String>>>>, outbound_message: OutboundMessage, ) -> Result<(), WebsocketServerError>

pub async fn broadcast_to_connections( connections: Vec<ClientConnection>, socket_message: SocketMessage, ) -> Result<(), WebsocketServerError>

pub async fn try_accept_new_connections( clients_map: Arc<RwLock<HashMap<String, ClientConnection>>>, listener: TcpListener, global_recv_tx: Sender<InboundMessage>, global_send_tx: Sender<OutboundMessage>, ws_server_events_tx: Sender<WebsocketSystemEvent>, ) -> Result<()>