Pika async consumer

[Josh Liberty]

I'm trying to understand how I can use an event loop (specifically asyncio) to run an asynchronous Pika consumer.

What I expect is a callback that'll be triggered whenever a message comes in, but won't block the event loop.

However, the example referred to in the docs (using SelectConnection or AsyncioConnection) uses an endless loop and never yields control back to the event loop - meaning that if I use those examples, the entire event loop hangs.

All other examples I found (on SO and so forth) used separate threads, in which case one can simply use a BlockingConnection. But that kind of misses the point, I think.

What am I missing?