(&mut self, payload: &[u8])
| 638 | } |
| 639 | |
| 640 | pub async fn write_frame(&mut self, payload: &[u8]) -> io::Result<()> { |
| 641 | let encoded = encode_frame(payload); |
| 642 | self.write_all(&encoded).await?; |
| 643 | self.flush().await |
| 644 | } |
| 645 | |
| 646 | pub async fn read_frame(&mut self) -> io::Result<Vec<u8>> { |
| 647 | let mut content_length = None; |
no test coverage detected