search

mosquito / aio-pika

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

QueueIterator implicit cancellation can be suppressed #623

Open pohmelie opened 3 months ago

pohmelie commented 3 months ago

https://github.com/mosquito/aio-pika/blob/master/aio_pika/queue.py#L530 Since there is a non-handled timeout on close call it is possible to suppress original asyncio.CancelledError exception and actually stuck, if caller code will handle TimeoutError.

Darsstar commented 3 months ago

I just refactored #615 a bit so that is should fix this issue.