Hello. Thanks for your contribution. However, I'd love to move try inside the while loop, because in case of any error prefetcher will stop working completely which will make worker to hang. It might happen, because of asyncio.wait for example.

Hello. Thanks for your contribution. However, I'd love to move try inside the while loop, because in case of any error prefetcher will stop working completely which will make worker to hang. It might happen, because of asyncio.wait for example.

That is a good point, I added a broad try ... except Exception in 592b167 and a test for transient listening failures in adeb379

Does that work for you or are there any concerns with calling iterator = self.broker.listen() in the exception handling?