Coverage for docs / docs_src / getting_started / asyncapi / asyncapi_customization / payload_info.py: 86%

1from pydantic import BaseModel, Field, NonNegativeFloat (empty)

2 

3from faststream import FastStream (empty)

4from faststream.kafka import KafkaBroker (empty)

5from faststream.specification import AsyncAPI (empty)

6 

7broker = KafkaBroker("localhost:9092") (empty)

8 

9app = FastStream(broker, specification=AsyncAPI()) (empty)

10 

11class DataBasic(BaseModel): (empty)

12 data: NonNegativeFloat = Field( (empty)

13 ..., examples=[0.5], description="Float data example", 

14 ) 

15 

16@broker.publisher("output_data") (empty)

17@broker.subscriber("input_data") (empty)

18async def on_input_data(msg: DataBasic) -> DataBasic: (empty)

19 return msg