(&self)
| 124 | .map_err(|err| NetError::from_io(NetErrorKind::SetNonBlocking, err))?; |
| 125 | Ok(Self { |
| 126 | stream, |
| 127 | peer, |
| 128 | frame_buf: VecDeque::new(), |
| 129 | tx_queue: VecDeque::new(), |
| 130 | tx_cursor: 0, |
| 131 | read_eof: false, |
no outgoing calls
no test coverage detected