Coverage for docs / docs_src / index / dependencies_annotated.py: 0%

1from typing import Annotated 

2 

3from faststream import Depends, Logger 

4from faststream.kafka import KafkaBroker 

5 

6broker = KafkaBroker() 

7 

8async def base_dep(user_id: int) -> bool: 

9 return True 

10 

11@broker.subscriber("in-test") 

12async def base_handler( 

13 user: str, 

14 logger: Logger, 

15 dep: Annotated[bool, Depends(base_dep)], 

16): 

17 assert dep is True 

18 logger.info(user)