Coverage for docs / docs_src / getting_started / manual_run / rabbit_base_run.py: 0%

1import asyncio 

2 

3from faststream import FastStream 

4from faststream.rabbit import RabbitBroker 

5 

6 

7async def main(): 

8 broker = RabbitBroker("amqp://guest:guest@localhost:5672/") 

9 app = FastStream(broker) 

10 await app.run() # blocking method 

11 

12if __name__ == "__main__": 

13 asyncio.run(main())