def _drain_queue(self):
    '\n        Drain the queue, yielding all items in it.\n        '
    while (not self._queue.empty()):
        try:
            (yield self._queue.get())
        except queue.Empty:
            break
Drain the queue, yielding all items in it.
def _drain_queue(self):
    '\n        \n        '
    while (not self._queue.empty()):
        try:
            (yield self._queue.get())
        except queue.Empty:
            break