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

1from faststream import FastStream (empty)

2from faststream.redis import RedisBroker (empty)

3from faststream.redis import RedisRouter, RedisRoute, RedisPublisher (empty)

4 

5broker = RedisBroker("redis://localhost:6379") (empty)

6app = FastStream(broker) (empty)

7 

8router = RedisRouter() (empty)

9 

10@router.subscriber("test-channel") (empty)

11@router.publisher("outer-channel") (empty)

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

13 assert name == "John" 

14 assert user_id == 1 

15 return "Hi!" 

16 

17broker.include_router(router) (empty)

18 

19@app.after_startup (empty)

20async def test(): (empty)

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