Function write_message

src/protocol.rs:34–47

Wire format: [4-byte length (big-endian)][MessagePack payload]

(writer: &mut W, msg: &T)

/// Wire format: [4-byte length (big-endian)][MessagePack payload]
pub async fn write_message<W, T>(writer: &mut W, msg: &T) -> std::io::Result<()>
where
    W: AsyncWriteExt + Unpin,
    T: Serialize,
{
    let payload = rmp_serde::to_vec(msg)
        .map_err(|e| std::io::Error::new(std::io::ErrorKind::InvalidData, e))?;

    let len = payload.len() as u32;
    writer.write_all(&len.to_be_bytes()).await?;
    writer.write_all(&payload).await?;
    writer.flush().await?;
    Ok(())
}

pub async fn read_message<R, T>(reader: &mut R) -> std::io::Result<T>
where