(&mut self, max_frame_bytes: usize)
| 197 | |
| 198 | pub fn write_handshake(&mut self, handshake: &NetHandshake) -> NetResult<()> { |
| 199 | self.write_frame(&handshake.encode()?) |
| 200 | } |
| 201 | |
| 202 | pub fn poll_frame(&mut self, max_frame_bytes: usize) -> NetResult<Option<Vec<u8>>> { |
| 203 | self.flush_pending()?; |
| 204 | if let Some(frame) = decode_next_queued_frame(&mut self.frame_buf, max_frame_bytes)? { |
| 205 | return Ok(Some(frame)); |
| 206 | } |
| 207 | self.read_into_frame_buf(max_frame_bytes)?; |
nothing calls this directly
no test coverage detected