Function read_until_ready

tests/client_compat.rs:1210–1220

(stream: &mut impl Read)

}

fn read_until_ready(stream: &mut impl Read) -> Result<Vec<RawBackendMessage>> {
    let mut messages = Vec::new();
    loop {
        let message = read_one_message(stream)?;
        let ready = message.tag == b'Z';
        messages.push(message);
        if ready {
            return Ok(messages);
        }
    }
}

fn read_until_copy_in_or_ready(stream: &mut impl Read) -> Result<Vec<RawBackendMessage>> {
    let mut messages = Vec::new();