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

1import asyncio 

2 

3from faststream import FastStream 

4from faststream.nats import NatsBroker 

5 

6 

7async def main(): 

8 broker = NatsBroker("nats://localhost:4222") 

9 app = FastStream(broker) 

10 await app.run() # blocking method 

11 

12if __name__ == "__main__": 

13 asyncio.run(main())