environment/lib/python2.7/site-packages/IPython/parallel/apps/logwatcher.py
def subscribe(self):
        """Update our SUB socket's subscriptions."""
        self.stream.setsockopt(zmq.UNSUBSCRIBE, '')
        if '' in self.topics:
            self.log.debug("Subscribing to: everything")
            self.stream.setsockopt(zmq.SUBSCRIBE, '')
        else:
            for topic in self.topics:
                self.log.debug("Subscribing to: %r"%(topic))
                self.stream.setsockopt(zmq.SUBSCRIBE, topic)
def subscribe(self):
        self.stream.setsockopt(zmq.UNSUBSCRIBE, '')
        if '' in self.topics:
            self.log.debug("Subscribing to: everything")
            self.stream.setsockopt(zmq.SUBSCRIBE, '')
        else:
            for topic in self.topics:
                self.log.debug("Subscribing to: %r"%(topic))
                self.stream.setsockopt(zmq.SUBSCRIBE, topic)
def subscribe ( self ) : self . stream . setsockopt ( zmq . UNSUBSCRIBE , '' ) if '' in self . topics : self . log . debug ( "Subscribing to: everything" ) self . stream . setsockopt ( zmq . SUBSCRIBE , '' ) else : for topic in self . topics : self . log . debug ( "Subscribing to: %r" % ( topic ) ) self . stream . setsockopt ( zmq . SUBSCRIBE , topic )
Update our SUB socket's subscriptions.
Update our SUB socket s subscriptions .