pub async fn recv_msg<T>(recv: &mut RecvStream) -> Result<T>where T: DeserializeOwned,
Receives a message as a stream.
Returns an error if receiving the message failed.