Coverage for docs / docs_src / getting_started / subscription / rabbit / dynamic_iter.py: 0%

1from faststream.rabbit import RabbitBroker, RabbitMessage 

2 

3async def main(): 

4 async with RabbitBroker() as broker: 

5 subscriber = broker.subscriber("test-queue", persistent=False) 

6 await subscriber.start() 

7 

8 async for msg in subscriber: # msg is RabbitMessage type 

9 ... # do message process 

10 

11 await subscriber.stop()