'for typ,data in pop_untagged_responses(): pass
Generator for any remaining untagged responses.
Returns and removes untagged responses in order of reception.
Use at your own risk!'

def pop_untagged_responses(self):

    while self.untagged_responses:
        self.commands_lock.acquire()
        try:
            (yield self.untagged_responses.pop(0))
        finally:
            self.commands_lock.release()
