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

1from msgspec import field 

2from fast_depends.msgspec import MsgSpecSerializer 

3 

4from faststream import FastStream 

5from faststream.rabbit import RabbitBroker 

6 

7broker = RabbitBroker( 

8 "amqp://guest:guest@localhost:5672/", 

9 serializer=MsgSpecSerializer(), 

10) 

11app = FastStream(broker) 

12 

13 

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

15async def handle( 

16 name: str, 

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

18): 

19 assert name == "John" 

20 assert user_id == 1