def unsubscribe_all(self): """ Subscription to all events. """ self.socket.setsockopt(zmq.UNSUBSCRIBE, '')