(&mut self, bytes: &[u8])
| 169 | return Ok(Some(NetEvent::TcpDisconnected { peer })); |
| 170 | } |
| 171 | Ok(Some(NetEvent::TcpData { peer, bytes })) |
| 172 | } |
| 173 | |
| 174 | pub fn write(&mut self, bytes: &[u8]) -> NetResult<usize> { |
| 175 | if !self.tx_queue.is_empty() { |
| 176 | self.enqueue_write(bytes.to_vec())?; |
| 177 | self.flush_pending()?; |