Method on_sleep

tests/unit/transport/test_consumer.py:1133–1137

(secs, **kwargs)

        i = 0

        def on_sleep(secs, **kwargs):
            nonlocal i
            if i > 1:
                consumer._stopped.set()
            i += 1

        consumer.sleep = AsyncMock(name="sleep", side_effect=on_sleep)
        consumer.commit = AsyncMock(name="commit")