pub async fn unsubscribe(&self, sub_id: WampId) -> Result<(), WampError> {
        // Send the request
        let (res, result) = oneshot::channel();
        if let Err(e) = self.ctl_channel.send(Request::Unsubscribe { sub_id, res }) {
            return Err(From::from(format!(
                "Core never received our request : {}",
                e
            )));
        }

        // Wait for the result
        match result.await {
            Ok(r) => r?,
            Err(e) => {
                return Err(From::from(format!(
                    "Core never returned a response : {}",
                    e
                )))
            }
        };

        Ok(())
    }
/// Unsubscribes to a previously subscribed topic
Unsubscribes to a previously subscribed topic
Unsubscribes to a previously subscribed topic
pub async fn unsubscribe(&self, sub_id: WampId) -> Result<(), WampError> {
        // Send the request
        let (res, result) = oneshot::channel();
        if let Err(e) = self.ctl_channel.send(Request::Unsubscribe { sub_id, res }) {
            return Err(From::from(format!(
                "Core never received our request : {}",
                e
            )));
        }
        // Wait for the result
        match result.await {
            Ok(r) => r?,
            Err(e) => {
                return Err(From::from(format!(
                    "Core never returned a response : {}",
                    e
                )))
            }
        };
        Ok(())
    }
pub async fn unsubscribe ( & self , sub_id : WampId ) -> Result < ( ) , WampError > { // Send the request let ( res , result ) = oneshot :: channel ( ) ; if let Err ( e ) = self . ctl_channel . send ( Request :: Unsubscribe { sub_id , res } ) { return Err ( From :: from ( format ! ( " " e ) ) ) ; } // Wait for the result match result . await { Ok ( r ) => r ? , Err ( e ) => { return Err ( From :: from ( format ! ( " " e ) ) ) } } ; Ok ( ( ) ) }
Unsubscribes to a previously subscribed topic
Unsubscribes to a previously subscribed topic
&self
sub_id
WampId