Struct WebSocketHandler 

pub struct WebSocketHandler { /* private fields */ }

WebSocket connection handler

Implementations

impl WebSocketHandler

pub fn new( server: Arc<WebSocketServer>, connection_id: String, ) -> (Self, UnboundedSender<WebSocketMessage>)

Create a new WebSocket handler

pub async fn handle_connection<T>( &mut self, ws_stream: WebSocketStream<T>, ) -> Result<(), Error>

where T: AsyncRead + AsyncWrite + Unpin + Send + 'static,

Handle WebSocket connection