Function recv_until

e2e/rust/tests/websocket_conformance.rs:119–132

(stream: &mut TcpStream, marker: &[u8])

}

async fn recv_until(stream: &mut TcpStream, marker: &[u8]) -> io::Result<Vec<u8>> {
    let mut data = Vec::new();
    let mut buf = [0_u8; 1024];
    loop {
        let read = stream.read(&mut buf).await?;
        if read == 0 {
            return Ok(data);
        }
        data.extend_from_slice(&buf[..read]);
        if data.windows(marker.len()).any(|window| window == marker) {
            return Ok(data);
        }
    }
}

async fn read_websocket_text(stream: &mut TcpStream) -> io::Result<String> {
    let mut header = [0_u8; 2];