Searched refs:stopping_queue (Results 1 – 1 of 1) sorted by relevance
53 stopping_queue = None variable58 global stopping_queue60 stopping_queue = stop_queue74 self._stopping_queue = stopping_queue168 def make_broker(self, starting_queue=None, stopping_queue=None): argument170 stopping_queue)194 stopping_queue = self.queue()195 self.make_broker(starting_queue, stopping_queue)202 stopping_queue.put('')