(&mut self, bytes: &[u8])
| 157 | Err(err) if err.kind() == io::ErrorKind::WouldBlock => Ok(None), |
| 158 | Err(err) => Err(NetError::from_io(NetErrorKind::Receive, err)), |
| 159 | } |
| 160 | } |
| 161 | |
| 162 | pub fn poll_event(&mut self, max_bytes: usize) -> NetResult<Option<NetEvent>> { |
| 163 | self.flush_pending()?; |
| 164 | let Some(bytes) = self.read_available(max_bytes)? else { |
| 165 | return Ok(None); |
| 166 | }; |
no outgoing calls