def loop(self, timeout=None):
        while True:
            try:
                self.drain_events(timeout)
            except Timeout:
                break
Call :meth:`drain_events` continuously
dataset/ETHPy150Open veegee/amqpy/amqpy/connection.py/Connection.loop