| docs/docs_src/confluent/ack/errors.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/confluent/basic/basic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/confluent/batch_consuming_pydantic/app.py |
5 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/confluent/consumes_basics/app.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/confluent/publish_batch/app.py |
11 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/confluent/publish_example/app.py |
8 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/confluent/publish_with_partition_key/app.py |
9 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/confluent/publisher_object/example.py |
12 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/confluent/raw_publish/example.py |
11 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/confluent/security/basic.py |
3 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/confluent/security/plaintext.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/confluent/security/sasl_scram256.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/confluent/security/sasl_scram512.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/confluent/security/ssl_warning.py |
3 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/asyncapi/asyncapi_customization/basic.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/asyncapi/asyncapi_customization/custom_broker.py |
5 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/asyncapi/asyncapi_customization/custom_handler.py |
6 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/asyncapi/asyncapi_customization/custom_info.py |
6 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/asyncapi/asyncapi_customization/payload_info.py |
6 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/asyncapi/serve.py |
5 |
0 |
0 |
0 |
0 |
100% |
| docs/docs_src/getting_started/cli/confluent_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/cli/kafka_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/cli/nats_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/cli/rabbit_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/cli/redis_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/config/settings_base_1.py |
4 |
0 |
1 |
0 |
0 |
100% |
| docs/docs_src/getting_started/config/settings_base_2.py |
4 |
0 |
1 |
0 |
0 |
100% |
| docs/docs_src/getting_started/config/settings_env.py |
4 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/config/usage.py |
8 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/annotated.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/base.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/cast.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/custom_global_context.py |
8 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/custom_local_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/default_arguments.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/existed_context.py |
8 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/fields_access.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/initial.py |
4 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/confluent/manual_local_context.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/annotated.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/base.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/cast.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/custom_global_context.py |
8 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/custom_local_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/default_arguments.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/existed_context.py |
8 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/fields_access.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/initial.py |
4 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/kafka/manual_local_context.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/annotated.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/base.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/cast.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/custom_global_context.py |
8 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/custom_local_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/default_arguments.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/existed_context.py |
8 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/fields_access.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/initial.py |
4 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nats/manual_local_context.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/nested.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/annotated.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/base.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/cast.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/custom_global_context.py |
8 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/custom_local_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/default_arguments.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/existed_context.py |
8 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/fields_access.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/initial.py |
4 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/rabbit/manual_local_context.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/annotated.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/base.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/cast.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/custom_global_context.py |
8 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/custom_local_context.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/default_arguments.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/existed_context.py |
8 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/fields_access.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/initial.py |
4 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/context/redis/manual_local_context.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/async_.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/confluent/depends.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/confluent/nested_depends.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/kafka/depends.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/kafka/nested_depends.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/nats/depends.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/nats/nested_depends.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/rabbit/depends.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/rabbit/nested_depends.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/redis/depends.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/redis/nested_depends.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic/sync.py |
7 |
0 |
1 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/basic_kafka.py |
10 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/class_kafka.py |
13 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/global_broker_kafka.py |
12 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/global_kafka.py |
12 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/sub_dep_kafka.py |
12 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/dependencies/yield_kafka.py |
14 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/index/base_confluent.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/index/base_kafka.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/index/base_nats.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/index/base_rabbit.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/index/base_redis.py |
5 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/confluent/basic.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/confluent/ml.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/confluent/ml_context.py |
14 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/confluent/testing.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/kafka/basic.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/kafka/ml.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/kafka/ml_context.py |
14 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/kafka/testing.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/multiple.py |
7 |
0 |
1 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/nats/basic.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/nats/ml.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/nats/ml_context.py |
14 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/nats/testing.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/rabbit/basic.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/rabbit/ml.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/rabbit/ml_context.py |
14 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/rabbit/testing.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/redis/basic.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/redis/ml.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/redis/ml_context.py |
14 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/lifespan/redis/testing.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/broker.py |
11 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/broker_context.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/decorator.py |
12 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/direct.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/direct_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/object.py |
10 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/confluent/object_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/broker.py |
11 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/broker_context.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/decorator.py |
12 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/direct.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/direct_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/object.py |
10 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/kafka/object_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/broker.py |
11 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/broker_context.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/decorator.py |
12 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/direct.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/direct_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/object.py |
10 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/nats/object_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/broker.py |
11 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/broker_context.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/decorator.py |
12 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/direct.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/direct_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/object.py |
10 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/rabbit/object_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/broker.py |
11 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/broker_context.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/decorator.py |
12 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/direct.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/direct_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/object.py |
10 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/publishing/redis/object_testing.py |
5 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/confluent/delay_equal.py |
13 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/confluent/router.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/confluent/router_delay.py |
11 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/kafka/delay_equal.py |
13 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/kafka/router.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/kafka/router_delay.py |
11 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/nats/delay_equal.py |
13 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/nats/router.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/nats/router_delay.py |
11 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/rabbit/delay_equal.py |
13 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/rabbit/router.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/rabbit/router_delay.py |
11 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/redis/delay_equal.py |
13 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/redis/router.py |
16 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/routers/redis/router_delay.py |
11 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/getting_started/serialization/parser_confluent.py |
11 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/serialization/parser_kafka.py |
11 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/serialization/parser_nats.py |
11 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/serialization/parser_rabbit.py |
11 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/serialization/parser_redis.py |
11 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/annotation.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/filter.py |
13 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/pydantic_annotated_fields.py |
3 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/pydantic_fields.py |
4 |
0 |
9 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/pydantic_model.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/real_testing.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/confluent/testing.py |
12 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/annotation.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/filter.py |
13 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/pydantic_annotated_fields.py |
3 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/pydantic_fields.py |
3 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/pydantic_model.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/real_testing.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/kafka/testing.py |
12 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/annotation.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/filter.py |
13 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/pydantic_annotated_fields.py |
3 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/pydantic_fields.py |
3 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/pydantic_model.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/real_testing.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/nats/testing.py |
12 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/annotation.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/filter.py |
13 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/pydantic_annotated_fields.py |
3 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/pydantic_fields.py |
3 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/pydantic_model.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/real_testing.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/rabbit/testing.py |
12 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/annotation.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/filter.py |
13 |
0 |
2 |
2 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/pydantic_annotated_fields.py |
3 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/pydantic_fields.py |
3 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/pydantic_model.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/real_testing.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/getting_started/subscription/redis/testing.py |
12 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/index/confluent/basic.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/index/confluent/pydantic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/index/confluent/test.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/index/dependencies.py |
6 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/index/kafka/basic.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/index/kafka/pydantic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/index/kafka/test.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/index/nats/basic.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/index/nats/pydantic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/index/nats/test.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/index/rabbit/basic.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/index/rabbit/pydantic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/index/rabbit/test.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/index/redis/basic.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/index/redis/pydantic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/index/redis/test.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/base.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/depends.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/multiple.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/multiple_lifespan.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/send.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/startup.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/confluent/test.py |
8 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/base.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/depends.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/multiple.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/multiple_lifespan.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/send.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/startup.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/kafka/test.py |
8 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/base.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/depends.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/multiple.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/multiple_lifespan.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/send.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/startup.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/nats/test.py |
8 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/base.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/depends.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/multiple.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/multiple_lifespan.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/send.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/startup.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/rabbit/test.py |
8 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/base.py |
14 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/depends.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/multiple.py |
9 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/multiple_lifespan.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/send.py |
7 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/startup.py |
9 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/integrations/fastapi/redis/test.py |
8 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/integrations/http_frameworks_integrations/fastapi.py |
13 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/kafka/ack/errors.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/kafka/basic/basic.py |
7 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/kafka/batch_consuming_pydantic/app.py |
5 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/kafka/consumes_basics/app.py |
5 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/kafka/publish_batch/app.py |
11 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/kafka/publish_example/app.py |
8 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/kafka/publish_with_partition_key/app.py |
9 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/kafka/publisher_object/example.py |
12 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/kafka/raw_publish/example.py |
11 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/kafka/security/basic.py |
3 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/kafka/security/plaintext.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/kafka/security/sasl_scram256.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/kafka/security/sasl_scram512.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/kafka/security/ssl_warning.py |
3 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/nats/ack/errors.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/nats/direct.py |
13 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/nats/js/key_value.py |
16 |
0 |
7 |
0 |
0 |
100% |
| docs/docs_src/nats/js/main.py |
9 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/nats/js/object.py |
16 |
0 |
8 |
0 |
0 |
100% |
| docs/docs_src/nats/js/pull_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/nats/pattern.py |
13 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/rabbit/ack/errors.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/rabbit/declare.py |
6 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/rabbit/security/basic.py |
3 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/rabbit/security/plaintext.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/rabbit/subscription/direct.py |
17 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/rabbit/subscription/fanout.py |
17 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/rabbit/subscription/header.py |
22 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/rabbit/subscription/index.py |
8 |
0 |
2 |
0 |
0 |
100% |
| docs/docs_src/rabbit/subscription/stream.py |
8 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/rabbit/subscription/topic.py |
17 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/redis/list/list_pub.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/redis/list/list_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/list/sub_batch.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/pub_sub/channel_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/pub_sub/channel_sub_pattern.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/pub_sub/pattern_data.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/pub_sub/publisher_decorator.py |
8 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/redis/pub_sub/publisher_object.py |
12 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/redis/pub_sub/raw_publish.py |
11 |
0 |
6 |
0 |
0 |
100% |
| docs/docs_src/redis/rpc/app.py |
17 |
0 |
5 |
0 |
0 |
100% |
| docs/docs_src/redis/security/basic.py |
3 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/security/plaintext.py |
2 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/redis/stream/ack_errors.py |
10 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/stream/batch_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/stream/group.py |
7 |
0 |
3 |
0 |
0 |
100% |
| docs/docs_src/redis/stream/pub.py |
7 |
0 |
4 |
0 |
0 |
100% |
| docs/docs_src/redis/stream/sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| examples/e01_basic_consume.py |
7 |
0 |
4 |
0 |
0 |
100% |
| examples/e02_1_basic_publisher.py |
11 |
0 |
5 |
0 |
0 |
100% |
| examples/e02_2_basic_publisher.py |
12 |
0 |
5 |
0 |
0 |
100% |
| examples/e02_3_basic_publisher.py |
11 |
0 |
5 |
0 |
0 |
100% |
| examples/e03_miltiple_pubsub.py |
16 |
0 |
6 |
0 |
0 |
100% |
| examples/e04_msg_filter.py |
10 |
0 |
5 |
2 |
0 |
100% |
| examples/e05_rpc_request.py |
8 |
0 |
4 |
0 |
0 |
100% |
| examples/e06_manual_ack.py |
8 |
0 |
4 |
0 |
0 |
100% |
| examples/e07_ack_immediately.py |
10 |
0 |
4 |
0 |
0 |
100% |
| examples/e08_testing.py |
10 |
0 |
3 |
0 |
0 |
100% |
| examples/e09_testing_mocks.py |
16 |
0 |
3 |
0 |
0 |
100% |
| examples/e10_middlewares.py |
21 |
0 |
4 |
0 |
0 |
100% |
| examples/e11_settings.py |
13 |
0 |
6 |
0 |
0 |
100% |
| examples/fastapi_integration/app.py |
8 |
0 |
3 |
0 |
0 |
100% |
| examples/fastapi_integration/testing.py |
14 |
0 |
5 |
0 |
0 |
100% |
| examples/kafka/ack_after_process.py |
7 |
0 |
3 |
0 |
0 |
100% |
| examples/kafka/batch_consume.py |
7 |
0 |
4 |
0 |
0 |
100% |
| examples/kafka/batch_publish_1.py |
7 |
0 |
4 |
0 |
0 |
100% |
| examples/kafka/batch_publish_2.py |
8 |
0 |
4 |
0 |
0 |
100% |
| examples/kafka/batch_publish_3.py |
11 |
0 |
4 |
0 |
0 |
100% |
| examples/kafka/testing.py |
16 |
0 |
3 |
0 |
0 |
100% |
| examples/nats/e01_basic.py |
7 |
0 |
3 |
0 |
0 |
100% |
| examples/nats/e02_basic_rpc.py |
9 |
0 |
3 |
0 |
0 |
100% |
| examples/nats/e03_publisher.py |
12 |
0 |
4 |
0 |
0 |
100% |
| examples/nats/e04_js_basic.py |
9 |
0 |
3 |
0 |
0 |
100% |
| examples/nats/e05_basic_and_js.py |
11 |
0 |
4 |
0 |
0 |
100% |
| examples/nats/e06_key_value.py |
16 |
0 |
6 |
0 |
0 |
100% |
| examples/nats/e07_object_storage.py |
16 |
0 |
7 |
0 |
0 |
100% |
| examples/nats/e08_wildcards.py |
10 |
0 |
4 |
0 |
0 |
100% |
| examples/nats/e09_pull_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| examples/rabbit/direct.py |
16 |
0 |
6 |
0 |
0 |
100% |
| examples/rabbit/fanout.py |
16 |
0 |
6 |
0 |
0 |
100% |
| examples/rabbit/header.py |
20 |
0 |
8 |
0 |
0 |
100% |
| examples/rabbit/stream.py |
8 |
0 |
3 |
0 |
0 |
100% |
| examples/rabbit/topic.py |
16 |
0 |
6 |
0 |
0 |
100% |
| examples/redis/channel_sub.py |
7 |
0 |
3 |
0 |
0 |
100% |
| examples/redis/channel_sub_pattern.py |
10 |
0 |
4 |
0 |
0 |
100% |
| examples/redis/list_sub.py |
7 |
0 |
3 |
0 |
0 |
100% |
| examples/redis/list_sub_batch.py |
7 |
0 |
3 |
0 |
0 |
100% |
| examples/redis/rpc.py |
17 |
0 |
5 |
0 |
0 |
100% |
| examples/redis/stream_sub.py |
7 |
0 |
3 |
0 |
0 |
100% |
| examples/redis/stream_sub_batch.py |
9 |
0 |
3 |
0 |
0 |
100% |
| examples/router/basic_consume.py |
9 |
0 |
3 |
0 |
0 |
100% |
| examples/router/basic_publish.py |
13 |
0 |
4 |
0 |
0 |
100% |
| examples/router/delay_registration.py |
8 |
0 |
3 |
0 |
0 |
100% |
| faststream/_compat.py |
64 |
9 |
31 |
0 |
0 |
86% |
| faststream/app.py |
84 |
3 |
22 |
16 |
0 |
97% |
| faststream/asyncapi/abc.py |
13 |
0 |
16 |
2 |
0 |
100% |
| faststream/asyncapi/generate.py |
85 |
2 |
10 |
56 |
2 |
97% |
| faststream/asyncapi/message.py |
50 |
0 |
9 |
28 |
0 |
100% |
| faststream/asyncapi/proto.py |
7 |
0 |
16 |
0 |
0 |
100% |
| faststream/asyncapi/schema/bindings/amqp.py |
26 |
0 |
3 |
0 |
0 |
100% |
| faststream/asyncapi/schema/bindings/kafka.py |
12 |
0 |
2 |
0 |
0 |
100% |
| faststream/asyncapi/schema/bindings/main.py |
30 |
0 |
8 |
6 |
0 |
100% |
| faststream/asyncapi/schema/bindings/nats.py |
9 |
0 |
2 |
0 |
0 |
100% |
| faststream/asyncapi/schema/bindings/redis.py |
11 |
0 |
2 |
0 |
0 |
100% |
| faststream/asyncapi/schema/bindings/sqs.py |
8 |
0 |
2 |
0 |
0 |
100% |
| faststream/asyncapi/schema/channels.py |
11 |
0 |
6 |
2 |
0 |
100% |
| faststream/asyncapi/schema/info.py |
36 |
1 |
32 |
6 |
0 |
98% |
| faststream/asyncapi/schema/main.py |
27 |
0 |
10 |
2 |
0 |
100% |
| faststream/asyncapi/schema/message.py |
22 |
0 |
4 |
4 |
0 |
100% |
| faststream/asyncapi/schema/operations.py |
13 |
0 |
6 |
2 |
0 |
100% |
| faststream/asyncapi/schema/security.py |
30 |
0 |
5 |
6 |
0 |
100% |
| faststream/asyncapi/schema/servers.py |
23 |
0 |
5 |
4 |
0 |
100% |
| faststream/asyncapi/schema/utils.py |
24 |
0 |
6 |
4 |
0 |
100% |
| faststream/asyncapi/site.py |
25 |
13 |
9 |
2 |
0 |
44% |
| faststream/asyncapi/utils.py |
18 |
0 |
2 |
10 |
0 |
100% |
| faststream/broker/acknowledgement_watcher.py |
75 |
2 |
41 |
20 |
0 |
98% |
| faststream/broker/core/abc.py |
38 |
0 |
21 |
16 |
2 |
96% |
| faststream/broker/core/logging.py |
6 |
0 |
27 |
0 |
0 |
100% |
| faststream/broker/core/usecase.py |
55 |
0 |
58 |
18 |
0 |
100% |
| faststream/broker/fastapi/context.py |
2 |
0 |
10 |
0 |
0 |
100% |
| faststream/broker/fastapi/get_dependant.py |
21 |
0 |
21 |
8 |
0 |
100% |
| faststream/broker/fastapi/route.py |
69 |
4 |
23 |
22 |
2 |
93% |
| faststream/broker/fastapi/router.py |
121 |
3 |
45 |
28 |
4 |
95% |
| faststream/broker/message.py |
44 |
2 |
11 |
16 |
2 |
93% |
| faststream/broker/middlewares/base.py |
38 |
0 |
6 |
12 |
0 |
100% |
| faststream/broker/middlewares/logging.py |
12 |
5 |
21 |
0 |
0 |
58% |
| faststream/broker/proto.py |
2 |
0 |
6 |
0 |
0 |
100% |
| faststream/broker/publisher/fake.py |
12 |
0 |
6 |
2 |
0 |
100% |
| faststream/broker/publisher/proto.py |
10 |
0 |
24 |
0 |
0 |
100% |
| faststream/broker/publisher/usecase.py |
40 |
0 |
19 |
6 |
0 |
100% |
| faststream/broker/router.py |
17 |
0 |
12 |
4 |
0 |
100% |
| faststream/broker/schemas.py |
19 |
1 |
3 |
6 |
1 |
92% |
| faststream/broker/subscriber/call_item.py |
41 |
3 |
35 |
12 |
3 |
89% |
| faststream/broker/subscriber/proto.py |
10 |
0 |
33 |
0 |
0 |
100% |
| faststream/broker/subscriber/usecase.py |
105 |
9 |
54 |
28 |
5 |
89% |
| faststream/broker/types.py |
18 |
0 |
6 |
0 |
0 |
100% |
| faststream/broker/utils.py |
35 |
0 |
19 |
6 |
0 |
100% |
| faststream/broker/wrapper/call.py |
56 |
1 |
43 |
20 |
1 |
97% |
| faststream/broker/wrapper/proto.py |
4 |
0 |
7 |
0 |
0 |
100% |
| faststream/cli/docs/app.py |
20 |
2 |
61 |
8 |
2 |
86% |
| faststream/cli/main.py |
18 |
3 |
91 |
0 |
0 |
83% |
| faststream/cli/supervisors/basereload.py |
29 |
0 |
19 |
4 |
0 |
100% |
| faststream/cli/supervisors/multiprocess.py |
10 |
0 |
13 |
2 |
0 |
100% |
| faststream/cli/supervisors/utils.py |
21 |
0 |
12 |
6 |
0 |
100% |
| faststream/cli/supervisors/watchfiles.py |
13 |
0 |
14 |
2 |
0 |
100% |
| faststream/cli/utils/imports.py |
46 |
7 |
17 |
12 |
2 |
84% |
| faststream/cli/utils/logs.py |
19 |
0 |
8 |
8 |
0 |
100% |
| faststream/cli/utils/parser.py |
29 |
0 |
4 |
17 |
0 |
100% |
| faststream/confluent/broker/broker.py |
30 |
1 |
50 |
6 |
1 |
94% |
| faststream/confluent/broker/logging.py |
1 |
0 |
24 |
0 |
0 |
100% |
| faststream/confluent/broker/registrator.py |
1 |
0 |
46 |
0 |
0 |
100% |
| faststream/confluent/client.py |
63 |
3 |
45 |
22 |
7 |
88% |
| faststream/confluent/fastapi/fastapi.py |
1 |
0 |
53 |
0 |
0 |
100% |
| faststream/confluent/message.py |
5 |
0 |
16 |
0 |
0 |
100% |
| faststream/confluent/parser.py |
20 |
1 |
28 |
6 |
2 |
88% |
| faststream/confluent/publisher/asyncapi.py |
16 |
0 |
23 |
0 |
0 |
100% |
| faststream/confluent/publisher/producer.py |
29 |
2 |
7 |
14 |
4 |
86% |
| faststream/confluent/publisher/usecase.py |
26 |
0 |
26 |
3 |
0 |
100% |
| faststream/confluent/router.py |
5 |
0 |
17 |
0 |
0 |
100% |
| faststream/confluent/schemas/params.py |
16 |
0 |
5 |
0 |
0 |
100% |
| faststream/confluent/security.py |
19 |
0 |
8 |
8 |
0 |
100% |
| faststream/confluent/subscriber/asyncapi.py |
20 |
1 |
22 |
2 |
0 |
95% |
| faststream/confluent/subscriber/usecase.py |
66 |
0 |
49 |
14 |
0 |
100% |
| faststream/confluent/testing.py |
74 |
7 |
17 |
18 |
2 |
88% |
| faststream/constants.py |
4 |
0 |
1 |
0 |
0 |
100% |
| faststream/exceptions.py |
27 |
7 |
1 |
0 |
0 |
74% |
| faststream/kafka/broker/broker.py |
40 |
19 |
72 |
4 |
0 |
57% |
| faststream/kafka/broker/logging.py |
1 |
0 |
23 |
0 |
0 |
100% |
| faststream/kafka/broker/registrator.py |
1 |
0 |
47 |
0 |
0 |
100% |
| faststream/kafka/fastapi/fastapi.py |
2 |
0 |
60 |
0 |
0 |
100% |
| faststream/kafka/message.py |
5 |
0 |
16 |
0 |
0 |
100% |
| faststream/kafka/parser.py |
12 |
0 |
18 |
2 |
0 |
100% |
| faststream/kafka/publisher/asyncapi.py |
16 |
0 |
23 |
0 |
0 |
100% |
| faststream/kafka/publisher/producer.py |
29 |
2 |
7 |
14 |
4 |
86% |
| faststream/kafka/publisher/usecase.py |
19 |
0 |
42 |
0 |
0 |
100% |
| faststream/kafka/router.py |
5 |
0 |
20 |
0 |
0 |
100% |
| faststream/kafka/schemas/params.py |
16 |
0 |
7 |
0 |
0 |
100% |
| faststream/kafka/security.py |
19 |
0 |
8 |
8 |
0 |
100% |
| faststream/kafka/subscriber/asyncapi.py |
20 |
1 |
34 |
2 |
0 |
95% |
| faststream/kafka/subscriber/usecase.py |
89 |
4 |
42 |
32 |
4 |
92% |
| faststream/kafka/testing.py |
55 |
5 |
19 |
28 |
3 |
88% |
| faststream/log/formatter.py |
13 |
0 |
3 |
4 |
1 |
94% |
| faststream/log/logging.py |
23 |
0 |
13 |
4 |
1 |
96% |
| faststream/nats/broker/broker.py |
114 |
43 |
56 |
24 |
4 |
62% |
| faststream/nats/broker/logging.py |
16 |
0 |
8 |
0 |
0 |
100% |
| faststream/nats/broker/registrator.py |
9 |
0 |
17 |
0 |
0 |
100% |
| faststream/nats/fastapi/fastapi.py |
7 |
0 |
35 |
0 |
0 |
100% |
| faststream/nats/helpers.py |
10 |
0 |
2 |
2 |
0 |
100% |
| faststream/nats/message.py |
33 |
12 |
3 |
20 |
2 |
53% |
| faststream/nats/parser.py |
38 |
1 |
8 |
12 |
3 |
92% |
| faststream/nats/publisher/asyncapi.py |
13 |
1 |
10 |
2 |
1 |
87% |
| faststream/nats/publisher/producer.py |
58 |
1 |
23 |
14 |
1 |
97% |
| faststream/nats/publisher/usecase.py |
24 |
1 |
12 |
5 |
1 |
93% |
| faststream/nats/router.py |
8 |
0 |
15 |
0 |
0 |
100% |
| faststream/nats/schemas/js_stream.py |
20 |
0 |
14 |
13 |
0 |
100% |
| faststream/nats/schemas/pull_sub.py |
6 |
0 |
2 |
0 |
0 |
100% |
| faststream/nats/security.py |
11 |
5 |
5 |
4 |
1 |
47% |
| faststream/nats/subscriber/asyncapi.py |
25 |
1 |
15 |
10 |
1 |
94% |
| faststream/nats/subscriber/usecase.py |
107 |
10 |
34 |
26 |
6 |
86% |
| faststream/nats/testing.py |
46 |
0 |
21 |
14 |
1 |
98% |
| faststream/rabbit/broker/broker.py |
64 |
2 |
48 |
22 |
4 |
93% |
| faststream/rabbit/broker/logging.py |
14 |
0 |
7 |
0 |
0 |
100% |
| faststream/rabbit/broker/registrator.py |
6 |
0 |
23 |
0 |
0 |
100% |
| faststream/rabbit/fastapi/router.py |
6 |
0 |
38 |
0 |
0 |
100% |
| faststream/rabbit/message.py |
19 |
0 |
2 |
6 |
0 |
100% |
| faststream/rabbit/parser.py |
19 |
0 |
10 |
4 |
0 |
100% |
| faststream/rabbit/publisher/asyncapi.py |
12 |
0 |
11 |
0 |
0 |
100% |
| faststream/rabbit/publisher/producer.py |
47 |
0 |
20 |
8 |
0 |
100% |
| faststream/rabbit/publisher/usecase.py |
46 |
0 |
18 |
3 |
0 |
100% |
| faststream/rabbit/router.py |
6 |
0 |
21 |
0 |
0 |
100% |
| faststream/rabbit/schemas/constants.py |
9 |
0 |
1 |
2 |
0 |
100% |
| faststream/rabbit/schemas/exchange.py |
4 |
0 |
23 |
0 |
0 |
100% |
| faststream/rabbit/schemas/proto.py |
5 |
0 |
3 |
0 |
0 |
100% |
| faststream/rabbit/schemas/queue.py |
7 |
0 |
20 |
0 |
0 |
100% |
| faststream/rabbit/schemas/reply.py |
8 |
0 |
2 |
0 |
0 |
100% |
| faststream/rabbit/security.py |
11 |
0 |
5 |
4 |
0 |
100% |
| faststream/rabbit/subscriber/asyncapi.py |
11 |
0 |
12 |
0 |
0 |
100% |
| faststream/rabbit/subscriber/usecase.py |
55 |
1 |
23 |
12 |
1 |
97% |
| faststream/rabbit/testing.py |
94 |
2 |
24 |
46 |
3 |
96% |
| faststream/rabbit/types.py |
1 |
1 |
4 |
0 |
0 |
0% |
| faststream/rabbit/utils.py |
20 |
0 |
16 |
2 |
0 |
100% |
| faststream/redis/broker/broker.py |
69 |
23 |
35 |
16 |
4 |
68% |
| faststream/redis/broker/logging.py |
11 |
0 |
8 |
0 |
0 |
100% |
| faststream/redis/broker/registrator.py |
8 |
0 |
18 |
0 |
0 |
100% |
| faststream/redis/fastapi/fastapi.py |
8 |
0 |
37 |
0 |
0 |
100% |
| faststream/redis/message.py |
48 |
0 |
9 |
2 |
0 |
100% |
| faststream/redis/parser.py |
76 |
0 |
8 |
12 |
0 |
100% |
| faststream/redis/publisher/asyncapi.py |
40 |
1 |
14 |
8 |
1 |
96% |
| faststream/redis/publisher/producer.py |
43 |
2 |
14 |
18 |
2 |
93% |
| faststream/redis/publisher/usecase.py |
92 |
3 |
17 |
12 |
6 |
91% |
| faststream/redis/router.py |
8 |
0 |
14 |
0 |
0 |
100% |
| faststream/redis/schemas/list_sub.py |
12 |
1 |
3 |
0 |
0 |
92% |
| faststream/redis/schemas/proto.py |
11 |
3 |
12 |
6 |
3 |
65% |
| faststream/redis/schemas/pub_sub.py |
12 |
0 |
2 |
4 |
0 |
100% |
| faststream/redis/schemas/stream_sub.py |
20 |
1 |
4 |
6 |
1 |
92% |
| faststream/redis/security.py |
19 |
1 |
6 |
6 |
1 |
92% |
| faststream/redis/subscriber/asyncapi.py |
45 |
1 |
16 |
10 |
1 |
96% |
| faststream/redis/subscriber/usecase.py |
150 |
4 |
49 |
22 |
2 |
97% |
| faststream/redis/testing.py |
62 |
0 |
17 |
28 |
0 |
100% |
| faststream/security.py |
29 |
0 |
23 |
4 |
0 |
100% |
| faststream/testing/app.py |
30 |
0 |
8 |
0 |
0 |
100% |
| faststream/testing/broker.py |
88 |
0 |
29 |
40 |
0 |
100% |
| faststream/types.py |
25 |
2 |
12 |
0 |
0 |
92% |
| faststream/utils/ast.py |
27 |
0 |
7 |
10 |
0 |
100% |
| faststream/utils/classes.py |
9 |
0 |
2 |
2 |
0 |
100% |
| faststream/utils/context/builders.py |
4 |
0 |
5 |
0 |
0 |
100% |
| faststream/utils/context/repository.py |
49 |
0 |
6 |
12 |
0 |
100% |
| faststream/utils/context/types.py |
7 |
0 |
23 |
2 |
0 |
100% |
| faststream/utils/data.py |
4 |
0 |
2 |
2 |
1 |
83% |
| faststream/utils/functions.py |
20 |
1 |
9 |
0 |
0 |
95% |
| faststream/utils/no_cast.py |
5 |
0 |
4 |
0 |
0 |
100% |
| faststream/utils/path.py |
27 |
4 |
3 |
10 |
3 |
81% |
| tests/asyncapi/base/arguments.py |
205 |
2 |
33 |
28 |
0 |
99% |
| tests/asyncapi/base/fastapi.py |
53 |
0 |
10 |
0 |
0 |
100% |
| tests/asyncapi/base/naming.py |
123 |
0 |
27 |
0 |
0 |
100% |
| tests/asyncapi/base/publisher.py |
66 |
0 |
12 |
12 |
0 |
100% |
| tests/asyncapi/base/router.py |
89 |
0 |
15 |
2 |
0 |
100% |
| tests/asyncapi/confluent/test_arguments.py |
8 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/confluent/test_connection.py |
9 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/confluent/test_fastapi.py |
12 |
0 |
11 |
0 |
0 |
100% |
| tests/asyncapi/confluent/test_naming.py |
7 |
0 |
5 |
0 |
0 |
100% |
| tests/asyncapi/confluent/test_publisher.py |
8 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/confluent/test_router.py |
24 |
0 |
7 |
0 |
0 |
100% |
| tests/asyncapi/confluent/test_security.py |
45 |
0 |
15 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_arguments.py |
8 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_connection.py |
9 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_fastapi.py |
12 |
0 |
11 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_naming.py |
7 |
0 |
5 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_publisher.py |
8 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_router.py |
24 |
0 |
7 |
0 |
0 |
100% |
| tests/asyncapi/kafka/test_security.py |
45 |
0 |
15 |
0 |
0 |
100% |
| tests/asyncapi/nats/test_arguments.py |
8 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/nats/test_connection.py |
9 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/nats/test_fastapi.py |
9 |
0 |
6 |
0 |
0 |
100% |
| tests/asyncapi/nats/test_naming.py |
7 |
0 |
5 |
0 |
0 |
100% |
| tests/asyncapi/nats/test_publisher.py |
8 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/nats/test_router.py |
24 |
0 |
7 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_arguments.py |
14 |
0 |
5 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_connection.py |
11 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_fastapi.py |
12 |
0 |
11 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_naming.py |
19 |
0 |
8 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_publisher.py |
24 |
0 |
7 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_router.py |
24 |
0 |
7 |
0 |
0 |
100% |
| tests/asyncapi/rabbit/test_security.py |
16 |
0 |
11 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_arguments.py |
32 |
0 |
8 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_connection.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_fastapi.py |
9 |
0 |
6 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_naming.py |
19 |
0 |
8 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_publisher.py |
20 |
0 |
6 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_router.py |
24 |
0 |
7 |
0 |
0 |
100% |
| tests/asyncapi/redis/test_security.py |
16 |
0 |
9 |
0 |
0 |
100% |
| tests/asyncapi/test_app.py |
15 |
0 |
4 |
0 |
0 |
100% |
| tests/brokers/base/connection.py |
35 |
1 |
3 |
0 |
0 |
97% |
| tests/brokers/base/consume.py |
127 |
0 |
8 |
10 |
0 |
100% |
| tests/brokers/base/fastapi.py |
271 |
1 |
15 |
10 |
0 |
99% |
| tests/brokers/base/middlewares.py |
193 |
1 |
6 |
12 |
0 |
99% |
| tests/brokers/base/parser.py |
109 |
0 |
5 |
6 |
0 |
100% |
| tests/brokers/base/publish.py |
161 |
0 |
13 |
2 |
0 |
100% |
| tests/brokers/base/router.py |
253 |
0 |
20 |
12 |
4 |
98% |
| tests/brokers/base/rpc.py |
44 |
0 |
14 |
0 |
0 |
100% |
| tests/brokers/base/testclient.py |
43 |
0 |
9 |
0 |
0 |
100% |
| tests/brokers/confluent/conftest.py |
28 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/confluent/test_connect.py |
5 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/confluent/test_consume.py |
97 |
0 |
10 |
4 |
1 |
99% |
| tests/brokers/confluent/test_fastapi.py |
28 |
0 |
7 |
2 |
0 |
100% |
| tests/brokers/confluent/test_middlewares.py |
5 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/confluent/test_parser.py |
5 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/confluent/test_publish.py |
42 |
0 |
5 |
8 |
3 |
94% |
| tests/brokers/confluent/test_router.py |
13 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/confluent/test_security.py |
57 |
0 |
14 |
0 |
0 |
100% |
| tests/brokers/confluent/test_test_client.py |
61 |
0 |
11 |
2 |
0 |
100% |
| tests/brokers/confluent/test_test_reentrancy.py |
38 |
10 |
4 |
0 |
0 |
74% |
| tests/brokers/conftest.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/brokers/kafka/conftest.py |
24 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/kafka/test_connect.py |
5 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/kafka/test_consume.py |
85 |
0 |
9 |
4 |
1 |
99% |
| tests/brokers/kafka/test_fastapi.py |
28 |
0 |
7 |
2 |
0 |
100% |
| tests/brokers/kafka/test_middlewares.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/kafka/test_parser.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/kafka/test_publish.py |
40 |
0 |
4 |
8 |
3 |
94% |
| tests/brokers/kafka/test_router.py |
9 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/kafka/test_stuff.py |
3 |
0 |
3 |
0 |
0 |
100% |
| tests/brokers/kafka/test_test_client.py |
82 |
0 |
15 |
2 |
0 |
100% |
| tests/brokers/kafka/test_test_reentrancy.py |
38 |
10 |
4 |
0 |
0 |
74% |
| tests/brokers/nats/conftest.py |
27 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/nats/test_connect.py |
5 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/nats/test_consume.py |
85 |
0 |
9 |
2 |
0 |
100% |
| tests/brokers/nats/test_fastapi.py |
47 |
0 |
8 |
2 |
0 |
100% |
| tests/brokers/nats/test_middlewares.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/nats/test_parser.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/nats/test_publish.py |
14 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/nats/test_router.py |
51 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/nats/test_rpc.py |
9 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/nats/test_test_client.py |
86 |
0 |
15 |
2 |
0 |
100% |
| tests/brokers/rabbit/conftest.py |
31 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/rabbit/core/test_call_manual.py |
43 |
0 |
2 |
0 |
0 |
100% |
| tests/brokers/rabbit/core/test_depends.py |
32 |
0 |
5 |
0 |
0 |
100% |
| tests/brokers/rabbit/specific/test_declare.py |
32 |
0 |
4 |
0 |
0 |
100% |
| tests/brokers/rabbit/specific/test_init.py |
7 |
0 |
2 |
0 |
0 |
100% |
| tests/brokers/rabbit/specific/test_nested_exchange.py |
13 |
0 |
3 |
0 |
0 |
100% |
| tests/brokers/rabbit/test_connect.py |
22 |
0 |
8 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_consume.py |
134 |
0 |
10 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_fastapi.py |
28 |
0 |
7 |
4 |
0 |
100% |
| tests/brokers/rabbit/test_middlewares.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_parser.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_publish.py |
19 |
0 |
7 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_router.py |
52 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_rpc.py |
2 |
0 |
3 |
0 |
0 |
100% |
| tests/brokers/rabbit/test_schemas.py |
4 |
0 |
1 |
0 |
0 |
100% |
| tests/brokers/rabbit/test_test_client.py |
128 |
0 |
16 |
2 |
0 |
100% |
| tests/brokers/rabbit/test_test_reentrancy.py |
38 |
10 |
4 |
0 |
0 |
74% |
| tests/brokers/redis/conftest.py |
26 |
0 |
4 |
2 |
0 |
100% |
| tests/brokers/redis/test_connect.py |
24 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/redis/test_consume.py |
184 |
0 |
12 |
14 |
4 |
98% |
| tests/brokers/redis/test_fastapi.py |
86 |
0 |
8 |
2 |
0 |
100% |
| tests/brokers/redis/test_middlewares.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/redis/test_parser.py |
3 |
0 |
3 |
2 |
0 |
100% |
| tests/brokers/redis/test_publish.py |
59 |
0 |
7 |
4 |
1 |
98% |
| tests/brokers/redis/test_router.py |
70 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/redis/test_rpc.py |
9 |
0 |
5 |
2 |
0 |
100% |
| tests/brokers/redis/test_schemas.py |
6 |
0 |
2 |
0 |
0 |
100% |
| tests/brokers/redis/test_test_client.py |
108 |
0 |
13 |
2 |
0 |
100% |
| tests/brokers/test_pushback.py |
64 |
0 |
4 |
6 |
0 |
100% |
| tests/cli/conftest.py |
12 |
0 |
4 |
0 |
0 |
100% |
| tests/cli/supervisors/test_base_reloader.py |
14 |
0 |
4 |
0 |
0 |
100% |
| tests/cli/supervisors/test_multiprocess.py |
9 |
0 |
7 |
2 |
0 |
100% |
| tests/cli/supervisors/test_watchfiles.py |
19 |
0 |
15 |
2 |
0 |
100% |
| tests/cli/test_app.py |
178 |
0 |
17 |
0 |
0 |
100% |
| tests/cli/test_asyncapi_docs.py |
51 |
0 |
10 |
0 |
0 |
100% |
| tests/cli/test_publish.py |
48 |
0 |
16 |
0 |
0 |
100% |
| tests/cli/test_version.py |
7 |
0 |
2 |
0 |
0 |
100% |
| tests/cli/utils/test_imports.py |
28 |
0 |
5 |
0 |
0 |
100% |
| tests/cli/utils/test_logs.py |
11 |
0 |
7 |
2 |
0 |
100% |
| tests/cli/utils/test_parser.py |
13 |
0 |
3 |
0 |
0 |
100% |
| tests/conftest.py |
30 |
0 |
8 |
2 |
0 |
100% |
| tests/docs/confluent/ack/test_errors.py |
8 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/confluent/basic/test_basic.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/confluent/basic/test_cmd_run.py |
11 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/confluent/batch_consuming_pydantic/test_app.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/confluent/consumes_basics/test_app.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/confluent/publish_batch/test_app.py |
12 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/confluent/publish_batch/test_issues.py |
11 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/confluent/publish_example/test_app.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/confluent/publish_with_partition_key/test_app.py |
13 |
4 |
3 |
0 |
0 |
69% |
| tests/docs/confluent/publisher_object/test_publisher_object.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/docs/confluent/raw_publish/test_raw_publish.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/docs/getting_started/asyncapi/asyncapi_customization/test_basic.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/asyncapi/asyncapi_customization/test_broker.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/asyncapi/asyncapi_customization/test_handler.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/asyncapi/asyncapi_customization/test_info.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/asyncapi/asyncapi_customization/test_payload.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/cli/test_confluent_context.py |
6 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/getting_started/cli/test_kafka_context.py |
6 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/getting_started/cli/test_nats_context.py |
6 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/getting_started/cli/test_rabbit_context.py |
6 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/getting_started/cli/test_redis_context.py |
6 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/getting_started/config/test_settings_base_1.py |
3 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/config/test_settings_base_2.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/getting_started/config/test_settings_env.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/getting_started/config/test_usage.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_annotated.py |
30 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_base.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_cast.py |
35 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_custom_global.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_custom_local.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_default_arguments.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_existed_context.py |
35 |
0 |
16 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_fields_access.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_initial.py |
40 |
0 |
13 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_manual_local_context.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/context/test_nested.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/basic/test_base.py |
1 |
0 |
2 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/basic/test_depends.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/basic/test_nested_depends.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/test_basic.py |
4 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/test_class.py |
4 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/test_global.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/test_global_broker.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/test_sub_dep.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/getting_started/dependencies/test_yield.py |
4 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/getting_started/index/test_basic.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/lifespan/test_basic.py |
30 |
0 |
14 |
0 |
0 |
100% |
| tests/docs/getting_started/lifespan/test_ml.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/lifespan/test_ml_context.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/lifespan/test_multi.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/getting_started/lifespan/test_testing.py |
5 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/getting_started/publishing/test_broker.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/publishing/test_broker_context.py |
30 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/publishing/test_decorator.py |
30 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/publishing/test_direct.py |
1 |
0 |
5 |
0 |
0 |
100% |
| tests/docs/getting_started/publishing/test_object.py |
1 |
0 |
5 |
0 |
0 |
100% |
| tests/docs/getting_started/routers/test_base.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/routers/test_delay.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/routers/test_delay_equal.py |
35 |
0 |
17 |
0 |
0 |
100% |
| tests/docs/getting_started/serialization/test_parser.py |
20 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/subscription/test_annotated.py |
40 |
0 |
13 |
2 |
0 |
100% |
| tests/docs/getting_started/subscription/test_filter.py |
25 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/getting_started/subscription/test_pydantic.py |
25 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/subscription/test_real.py |
10 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/getting_started/subscription/test_testing.py |
1 |
0 |
10 |
0 |
0 |
100% |
| tests/docs/index/test_basic.py |
30 |
0 |
11 |
0 |
0 |
100% |
| tests/docs/index/test_dependencies.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/index/test_pydantic.py |
1 |
0 |
10 |
0 |
0 |
100% |
| tests/docs/integration/fastapi/test_base.py |
40 |
0 |
12 |
0 |
0 |
100% |
| tests/docs/integration/fastapi/test_depends.py |
35 |
0 |
17 |
0 |
0 |
100% |
| tests/docs/integration/fastapi/test_multiple.py |
35 |
0 |
7 |
14 |
1 |
98% |
| tests/docs/integration/fastapi/test_multiple_lifespan.py |
39 |
0 |
9 |
14 |
1 |
98% |
| tests/docs/integration/fastapi/test_send.py |
35 |
0 |
17 |
0 |
0 |
100% |
| tests/docs/integration/fastapi/test_startup.py |
30 |
0 |
17 |
0 |
0 |
100% |
| tests/docs/integration/fastapi/test_test.py |
1 |
0 |
5 |
0 |
0 |
100% |
| tests/docs/integration/http/test_fastapi.py |
7 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/kafka/ack/test_errors.py |
8 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/kafka/basic/test_basic.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/kafka/basic/test_cmd_run.py |
11 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/kafka/batch_consuming_pydantic/test_app.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/kafka/consumes_basics/test_app.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/kafka/publish_batch/test_app.py |
12 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/kafka/publish_batch/test_issues.py |
11 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/kafka/publish_example/test_app.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/kafka/publish_with_partition_key/test_app.py |
13 |
4 |
3 |
0 |
0 |
69% |
| tests/docs/kafka/publisher_object/test_publisher_object.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/docs/kafka/raw_publish/test_raw_publish.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/docs/kafka/test_security.py |
53 |
0 |
14 |
0 |
0 |
100% |
| tests/docs/nats/ack/test_errors.py |
7 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/nats/js/test_kv.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/nats/js/test_main.py |
4 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/nats/js/test_object.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/nats/js/test_pull_sub.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/nats/test_direct.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/nats/test_pattern.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/ack/test_errors.py |
7 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/rabbit/subscription/test_direct.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/subscription/test_fanout.py |
8 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/subscription/test_header.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/subscription/test_index.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/subscription/test_stream.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/subscription/test_topic.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/test_declare.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/rabbit/test_security.py |
13 |
0 |
9 |
0 |
0 |
100% |
| tests/docs/redis/list/test_list_pub.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/list/test_list_sub.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/list/test_sub_batch.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/redis/pub_sub/test_channel_sub.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/pub_sub/test_channel_sub_pattern.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/pub_sub/test_pattern_data.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/pub_sub/test_publihser_object.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/docs/redis/pub_sub/test_publisher_decorator.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/pub_sub/test_raw_publish.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/docs/redis/stream/test_ack_errors.py |
8 |
0 |
6 |
0 |
0 |
100% |
| tests/docs/redis/stream/test_batch_sub.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/redis/stream/test_group.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/stream/test_pub.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/stream/test_sub.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/docs/redis/test_rpc.py |
3 |
0 |
4 |
0 |
0 |
100% |
| tests/docs/redis/test_security.py |
30 |
0 |
11 |
0 |
0 |
100% |
| tests/examples/fastapi_integration/test_app.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/examples/kafka/test_ack.py |
5 |
0 |
6 |
0 |
0 |
100% |
| tests/examples/kafka/test_batch_consume.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/kafka/test_batch_publish_1.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/kafka/test_batch_publish_2.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/kafka/test_batch_publish_3.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/kafka/test_example.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/examples/nats/test_e01_basic.py |
4 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e02_basic_rpc.py |
4 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e03_publisher.py |
5 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e04_js_basic.py |
5 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e05_basic_and_js.py |
5 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e06_key_value.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e07_object_storage.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e08_wildcards.py |
6 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/nats/test_e09_pull_sub.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/rabbit/test_direct.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/rabbit/test_fanout.py |
8 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/rabbit/test_header.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/rabbit/test_stream.py |
6 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/rabbit/test_topic.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/redis/test_channel_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/redis/test_channel_sub_pattern.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/redis/test_list_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/redis/test_list_sub_batch.py |
5 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/redis/test_rpc.py |
3 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/redis/test_stream_batch_sub.py |
5 |
0 |
4 |
0 |
0 |
100% |
| tests/examples/redis/test_stream_sub.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/router/test_basic_consume.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/router/test_basic_publish.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/router/test_delay_registration.py |
8 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e01_basic_consume.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e02_1_basic_publisher.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e02_2_basic_publisher.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e02_3_basic_publisher.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e03_miltiple_pubsub.py |
9 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e04_msg_filter.py |
7 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e05_rpc_request.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e06_manual_ack.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e07_ack_immediately.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e08_testing.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/examples/test_e09_testing_mocks.py |
1 |
0 |
1 |
0 |
0 |
100% |
| tests/examples/test_e10_middlewares.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/examples/test_e11_settings.py |
5 |
0 |
3 |
0 |
0 |
100% |
| tests/log/test_formatter.py |
5 |
0 |
4 |
0 |
0 |
100% |
| tests/marks.py |
4 |
0 |
3 |
0 |
0 |
100% |
| tests/mocks.py |
7 |
0 |
4 |
0 |
0 |
100% |
| tests/tools.py |
14 |
3 |
2 |
0 |
0 |
79% |
| tests/utils/context/test_alias.py |
37 |
0 |
4 |
0 |
0 |
100% |
| tests/utils/context/test_depends.py |
37 |
0 |
5 |
0 |
0 |
100% |
| tests/utils/context/test_headers.py |
10 |
0 |
3 |
0 |
0 |
100% |
| tests/utils/context/test_main.py |
103 |
0 |
4 |
0 |
0 |
100% |
| tests/utils/context/test_path.py |
40 |
0 |
5 |
0 |
0 |
100% |
| tests/utils/test_ast.py |
47 |
0 |
5 |
0 |
0 |
100% |
| tests/utils/test_classes.py |
6 |
0 |
1 |
0 |
0 |
100% |
| tests/utils/test_functions.py |
10 |
0 |
2 |
0 |
0 |
100% |
| tests/utils/test_handler_lock.py |
45 |
0 |
5 |
0 |
0 |
100% |
| tests/utils/test_no_cast.py |
5 |
0 |
2 |
0 |
0 |
100% |
| tests/utils/type_cast/test_base.py |
24 |
0 |
3 |
0 |
0 |
100% |
| tests/utils/type_cast/test_model.py |
14 |
0 |
4 |
0 |
0 |
100% |