Multiple readers work synchronously

read_async_iter.py

import asyncio
import aio_pika

async def read(reader_id):
    connection = await aio_pika.connect_robust(**RMQ_CONFIG)
    async with connection:
        channel = await connection.channel()
        queue = await channel.declare_queue('test_queue', durable=True)
        message = await queue.get()
        
        # the difference is here
        async for message in queue:
            with message.process():
                print(reader_id)
                await asyncio.sleep(1)  # emulate async task

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    readers = [read(i) for i in range(3)]
    loop.run_until_complete(asyncio.wait(readers))