Method read_message

perro_source/api_modules/perro_networking/src/websocket.rs:277–290

(&mut self, max_bytes: usize)

    }

    pub fn read_message(&mut self, max_bytes: usize) -> NetResult<Option<WebSocketMessage>> {
        let max_bytes = max_bytes.min(self.max_message_bytes);
        match self.socket.read() {
            Ok(message) => map_websocket_message(message, max_bytes).map(Some),
            Err(tungstenite::Error::Io(err)) if err.kind() == io::ErrorKind::WouldBlock => Ok(None),
            Err(tungstenite::Error::ConnectionClosed) | Err(tungstenite::Error::AlreadyClosed) => {
                Ok(Some(WebSocketMessage::Close {
                    code: None,
                    reason: String::new(),
                }))
            }
            Err(err) => Err(NetError::new(NetErrorKind::WebSocket, err.to_string())),
        }
    }

    pub fn poll_event(&mut self, max_bytes: usize) -> NetResult<Option<NetEvent>> {
        let Some(message) = self.read_message(max_bytes)? else {