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

1import asyncio 

2 

3from faststream import FastStream 

4from faststream.redis import RedisBroker 

5 

6 

7async def main(): 

8 broker = RedisBroker("redis://localhost:6379") 

9 app = FastStream(broker) 

10 await app.run() # blocking method 

11 

12if __name__ == "__main__": 

13 asyncio.run(main())