(&mut self, bytes: Bytes)
| 165 | |
| 166 | #[inline] |
| 167 | pub async fn send_bytes(&mut self, bytes: Bytes) -> ResultType<()> { |
| 168 | if self.3 > 0 { |
| 169 | super::timeout(self.3, self.0.send(bytes)).await??; |
| 170 | } else { |
| 171 | self.0.send(bytes).await?; |
| 172 | } |
| 173 | Ok(()) |
| 174 | } |
| 175 | |
| 176 | #[inline] |
| 177 | pub async fn next(&mut self) -> Option<Result<BytesMut, Error>> { |