Coverage for docs / docs_src / getting_started / routers / nats / delay_equal.py: 69%

1from faststream import FastStream (empty)

2from faststream.nats import NatsBroker, NatsRouter (empty)

3 

4broker = NatsBroker("nats://localhost:4222") (empty)

5app = FastStream(broker) (empty)

6 

7router = NatsRouter() (empty)

8 

9@router.subscriber("test-subject") (empty)

10@router.publisher("outer-subject") (empty)

11async def handle(name: str, user_id: int): (empty)

12 assert name == "John" 

13 assert user_id == 1 

14 return "Hi!" 

15 

16broker.include_router(router) (empty)

17 

18@app.after_startup (empty)

19async def test(): (empty)

20 await broker.publish({"name": "John", "user_id": 1}, subject="test-subject")