connectordb/_websocket.py
def unsubscribe(self, stream, transform=""):
        """Unsubscribe from the given stream (with the optional transform)"""
        if self.status is not "connected":
            return False
        logging.debug("Unsubscribing from %s", stream)
        self.send(
            {"cmd": "unsubscribe",
             "arg": stream,
             "transform": transform})

        self.subscription_lock.acquire()
        del self.subscriptions[stream + ":" + transform]
        if len(self.subscriptions) is 0:
            self.subscription_lock.release()
            self.disconnect()
        else:
            self.subscription_lock.release()
def unsubscribe(self, stream, transform=""):
        """Unsubscribe from the given stream (with the optional transform)"""
        if self.status is not "connected":
            return False
        logging.debug("Unsubscribing from %s", stream)
        self.send(
            {"cmd": "unsubscribe",
             "arg": stream,
             "transform": transform})

        self.subscription_lock.acquire()
        del self.subscriptions[stream + ":" + transform]
        if len(self.subscriptions) is 0:
            self.subscription_lock.release()
            self.disconnect()
        else:
            self.subscription_lock.release()
def unsubscribe ( self , stream , transform = "" ) : if self . status is not "connected" : return False logging . debug ( "Unsubscribing from %s" , stream ) self . send ( { "cmd" : "unsubscribe" , "arg" : stream , "transform" : transform } ) self . subscription_lock . acquire ( ) del self . subscriptions [ stream + ":" + transform ] if len ( self . subscriptions ) is 0 : self . subscription_lock . release ( ) self . disconnect ( ) else : self . subscription_lock . release ( )
Unsubscribe from the given stream (with the optional transform)
Unsubscribe from the given stream ( with the optional transform )