def _wait_store(self):
        while True:
            try:
                for entry in self.store.wait():
                    self._add_queued(entry)
            except __HOLE__:
                return
dataset/ETHPy150Open slimta/python-slimta/slimta/queue/__init__.py/Queue._wait_store