(&mut self, max_bytes: usize)
| 290 | } |
| 291 | |
| 292 | pub fn poll_event(&mut self, max_bytes: usize) -> NetResult<Option<NetEvent>> { |
| 293 | let Some(message) = self.read_message(max_bytes)? else { |
| 294 | return Ok(None); |
| 295 | }; |
| 296 | let peer = self.peer_string(); |
| 297 | Ok(Some(match message { |
| 298 | WebSocketMessage::Text(text) => NetEvent::WebSocketText { peer, text }, |
| 299 | WebSocketMessage::Binary(bytes) => NetEvent::WebSocketBinary { peer, bytes }, |
| 300 | WebSocketMessage::Ping(bytes) => NetEvent::WebSocketPing { peer, bytes }, |
| 301 | WebSocketMessage::Pong(bytes) => NetEvent::WebSocketPong { peer, bytes }, |
| 302 | WebSocketMessage::Close { code, reason } => { |
| 303 | NetEvent::WebSocketClosed { peer, code, reason } |
| 304 | } |
| 305 | })) |
| 306 | } |
| 307 | |
| 308 | pub fn poll_event_default(&mut self) -> NetResult<Option<NetEvent>> { |
| 309 | self.poll_event(self.max_message_bytes) |
no test coverage detected