9414aa43a36a99e200b350648604026ef2c963df,studio/pubsub_queue.py,PubsubQueue,clean,#PubsubQueue#,49

Before Change

        self.logger.info("subscription {} created".format(sub_name))

    def clean(self):
        while self.has_next():
            self.dequeue()

    def get_name(self):
        return self.subclient.match_topic_from_topic_name(self.topic_name)

After Change

        self.logger.info("subscription {} created".format(sub_name))

    def clean(self):
        while True:
            msg = self.dequeue()
            if not msg:
                break

    def get_name(self):
        return self.subclient.match_topic_from_topic_name(self.topic_name)

    def has_next(self):

Instances