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

1from msgspec import field, Struct 

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 

14class UserInfo(Struct): 

15 name: str 

16 user_id: int = field(name="userId") 

17 

18 

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

20async def handle( 

21 user: UserInfo, 

22): 

23 assert user.name == "John" 

24 assert user.user_id == 1