pub async fn recv_message<T: DeserializeOwned>( stream: &mut (impl AsyncRead + Unpin), ) -> Result<Option<T>>