search

mosquito / aio-pika

AMQP 0.9 client designed for asyncio and humans.
https://aio-pika.readthedocs.org/
Apache License 2.0
1.24k stars 189 forks source link

Timeout not work with queue iterator #325

Open heckad opened 4 years ago

heckad commented 4 years ago 
        async with queue.iterator(timeout=10) as queue_iter:
            async for message in queue_iter:
                async with message.process():
                    print(message.body)

This code works endlessly

romuald commented 4 years ago

@heckad thanks for the fix!

Any idea when the next release will be?