Coverage for docs / docs_src / getting_started / subscription / redis / msgspec_fields.py: 0%

1from msgspec import field 

2from fast_depends.msgspec import MsgSpecSerializer 

3 

4from faststream import FastStream 

5from faststream.redis import RedisBroker 

6 

7broker = RedisBroker( 

8 "redis://localhost:6379", 

9 serializer=MsgSpecSerializer(), 

10) 

11app = FastStream(broker) 

12 

13 

14@broker.subscriber("test-channel") 

15async def handle( 

16 name: str, 

17 user_id: int = field(name="userId"), 

18): 

19 assert name == "John" 

20 assert user_id == 1