Method recv

recipes/Python/577001_sqlite_message_bus/recipe-577001.py:74–82

(self, tag='*', func=lambda _: True, wait=5, sleep=0.5)

    # PUBLIC
    def recv (self, tag='*', func=lambda _: True, wait=5, sleep=0.5):
        end = time.time() + wait
        while True:
            self._poll()
            for t in self._filter(tag, func):
                yield t
            if time.time() > end:
                break
            time.sleep(sleep)

    def send (self, dest, tag, **kwargs):
        data  = (tag, kwargs)