(&mut self, handshake: &NetHandshake)
| 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()?; |
| 178 | return Ok(bytes.len()); |
| 179 | } |
| 180 | self.stream |
| 181 | .write(bytes) |
no test coverage detected