connectordb/_websocket.py
def __resubscribe(self):
        """Send subscribe command for all existing subscriptions. This allows to resume a connection
        that was closed"""
        with self.subscription_lock:
            for sub in self.subscriptions:
                logging.debug("Resubscribing to %s", sub)
                stream_transform = sub.split(":", 1)
                self.send({
                    "cmd": "subscribe",
                    "arg": stream_transform[0],
                    "transform": stream_transform[1]
                })
def __resubscribe(self):
        """Send subscribe command for all existing subscriptions. This allows to resume a connection
        that was closed"""
        with self.subscription_lock:
            for sub in self.subscriptions:
                logging.debug("Resubscribing to %s", sub)
                stream_transform = sub.split(":", 1)
                self.send({
                    "cmd": "subscribe",
                    "arg": stream_transform[0],
                    "transform": stream_transform[1]
                })
def __resubscribe ( self ) : with self . subscription_lock : for sub in self . subscriptions : logging . debug ( "Resubscribing to %s" , sub ) stream_transform = sub . split ( ":" , 1 ) self . send ( { "cmd" : "subscribe" , "arg" : stream_transform [ 0 ] , "transform" : stream_transform [ 1 ] } )
Send subscribe command for all existing subscriptions. This allows to resume a connection
        that was closed
Send subscribe command for all existing subscriptions . This allows to resume a connection that was closed