pub async fn recv<'b>(&'b mut self) -> Result<Msg, WampError>
    where
        'a: 'b,
    {
        // Receive a full message from the host
        let payload = self.sock.recv().await?;

        // Deserialize into a Msg
        let msg = self.serializer.unpack(&payload);

        match std::str::from_utf8(&payload) {
            Ok(v) => debug!("Recv : {}", v),
            Err(_) => debug!("Recv : {:?}", msg),
        };

        Ok(msg?)
    }
/// Receives a message and deserializes it
Receives a message and deserializes it
Receives a message and deserializes it
pub async fn recv<'b>(&'b mut self) -> Result<Msg, WampError>
    where
        'a: 'b,
    {
        // Receive a full message from the host
        let payload = self.sock.recv().await?;
        // Deserialize into a Msg
        let msg = self.serializer.unpack(&payload);
        match std::str::from_utf8(&payload) {
            Ok(v) => debug!("Recv : {}", v),
            Err(_) => debug!("Recv : {:?}", msg),
        };
        Ok(msg?)
    }
pub async fn recv < ' b > ( & ' b mut self ) -> Result < Msg , WampError > where ' a : ' b , { // Receive a full message from the host let payload = self . sock . recv ( ) . await ? ; // Deserialize into a Msg let msg = self . serializer . unpack ( & payload ) ; match std :: str :: from_utf8 ( & payload ) { Ok ( v ) => debug ! ( " " v ) , Err ( _ ) => debug ! ( " " msg ) , } ; Ok ( msg ? ) }
Receives a message and deserializes it
Receives a message and deserializes it
&'b mut self