Function read_one_message

tests/client_compat.rs:1241–1257

(stream: &mut impl Read)

}

fn read_one_message(stream: &mut impl Read) -> Result<RawBackendMessage> {
    let mut header = [0u8; 5];
    stream
        .read_exact(&mut header)
        .context("read backend message header")?;
    let len = i32::from_be_bytes([header[1], header[2], header[3], header[4]]);
    anyhow::ensure!(len >= 4, "invalid backend message length {len}");
    let body_len = (len - 4) as usize;
    let mut body = vec![0u8; body_len];
    stream
        .read_exact(&mut body)
        .context("read backend message body")?;
    Ok(RawBackendMessage {
        tag: header[0],
        body,
    })
}

fn read_startup_error_sqlstate(stream: &mut impl Read) -> Result<Option<String>> {
    loop {