Function write_message

common/src/protocol.rs:326–348

(
    conn: &mut T,
    msg: &message::Message,
)

}

pub async fn write_message<T: AsyncWrite + Unpin>(
    conn: &mut T,
    msg: &message::Message,
) -> Result<()> {
    let proto_msg = Message {
        message: Some(msg.clone()),
    };

    debug!("Sending proto message: {:?}", msg);

    let mut buf = BytesMut::new();
    proto_msg
        .encode(&mut buf)
        .context("Failed to encode Protocol Buffers message")?;

    let len = buf.len() as u32;
    let len_bytes = len.to_le_bytes();

    conn.write_all(&len_bytes).await?;
    conn.write_all(&buf).await?;
    conn.flush().await?;
    Ok(())
}

impl FairGroup for message::Message {
    fn group_id(&self) -> Option<u32> {