(&mut self, bytes: &[u8])
| 163 | self.flush_pending()?; |
| 164 | let Some(bytes) = self.read_available(max_bytes)? else { |
| 165 | return Ok(None); |
| 166 | }; |
| 167 | let peer = self.peer_string(); |
| 168 | if bytes.is_empty() { |
| 169 | return Ok(Some(NetEvent::TcpDisconnected { peer })); |
| 170 | } |
| 171 | Ok(Some(NetEvent::TcpData { peer, bytes })) |
| 172 | } |
no outgoing calls