pub async fn read_message<Rd: AsyncRead + Unpin>(
r: &mut Rd,
) -> Result<Option<Message>>Expand description
Read one message. Its announced size is checked against MAX_MESSAGE_BYTES from the
fixed header, before the rest is read. Ok(None) at a clean end of stream.