pub async fn recv_extra<T: Serialize + DeserializeOwned>(
        &mut self,
    ) -> Result<(T, <Inner as RecvBytes>::RecvExtra), ReceiveError> {
        let (msg, extra) = self.i.recv_extra().await?;
        Ok((self.decrypt_msg(&msg)?, extra))
    }
/// Asynchronously wait to receive a message from this stream (with the given decryption context).
Asynchronously wait to receive a message from this stream (with the given decryption context).
Asynchronously wait to receive a message from this stream ( with the given decryption context ) .
pub async fn recv_extra<T: Serialize + DeserializeOwned>(
        &mut self,
    ) -> Result<(T, <Inner as RecvBytes>::RecvExtra), ReceiveError> {
        let (msg, extra) = self.i.recv_extra().await?;
        Ok((self.decrypt_msg(&msg)?, extra))
    }
pub async fn recv_extra < T : Serialize + DeserializeOwned > ( & mut self , ) -> Result < ( T , < Inner as RecvBytes > :: RecvExtra ) , ReceiveError > { let ( msg , extra ) = self . i . recv_extra ( ) . await ? ; Ok ( ( self . decrypt_msg ( & msg ) ? , extra ) ) }
Asynchronously wait to receive a message from this stream (with the given decryption context).
Asynchronously wait to receive a message from this stream ( with the given decryption context ) .
&mut self
&mut self