pub async fn read_message_bytes<S>( stream: &mut S, ) -> Result<(u8, BytesMut), Error>where S: AsyncRead + Unpin,