Read the next text message from the WebSocket, skipping non-text frames.
(&mut self)
| 645 | |
| 646 | /// Read the next text message from the WebSocket, skipping non-text frames. |
| 647 | pub async fn read_text(&mut self) -> Result<String> { |
| 648 | loop { |
| 649 | match self.read.next().await { |
| 650 | Some(Ok(Message::Text(text))) => return Ok(text.to_string()), |
| 651 | Some(Ok(Message::Close(_))) => bail!("WebSocket closed by server"), |
| 652 | Some(Ok(_)) => continue, |
| 653 | Some(Err(e)) => bail!("WebSocket error: {e}"), |
| 654 | None => bail!("WebSocket connection closed"), |
| 655 | } |
| 656 | } |
| 657 | } |
| 658 | |
| 659 | // ── Target domain helpers ── |
| 660 |
no outgoing calls
no test coverage detected