| docs / docs_src / confluent / security / custom_config.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / asyncapi / asyncapi_customization / payload_info.py |
on_input_data |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / asyncapi / serve.py |
(no function) |
|
0% |
5 |
5 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / config / settings_base_1.py |
(no function) |
|
0% |
4 |
4 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / confluent / basic.py |
setup |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / confluent / basic.py |
(no function) |
|
0% |
6 |
6 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / kafka / basic.py |
setup |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / kafka / basic.py |
(no function) |
|
0% |
6 |
6 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / nats / basic.py |
setup |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / nats / basic.py |
(no function) |
|
0% |
6 |
6 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / rabbit / basic.py |
setup |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / rabbit / basic.py |
(no function) |
|
0% |
6 |
6 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / redis / basic.py |
setup |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / redis / basic.py |
(no function) |
|
0% |
6 |
6 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / confluent_base_run.py |
main |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / confluent_base_run.py |
(no function) |
|
0% |
1 |
1 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / kafka_base_run.py |
main |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / kafka_base_run.py |
(no function) |
|
0% |
1 |
1 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / nats_base_run.py |
main |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / nats_base_run.py |
(no function) |
|
0% |
1 |
1 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / rabbit_base_run.py |
main |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / rabbit_base_run.py |
(no function) |
|
0% |
1 |
1 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / redis_base_run.py |
main |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / redis_base_run.py |
(no function) |
|
0% |
1 |
1 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / confluent_telemetry.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / kafka_telemetry.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / mqtt_telemetry.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / nats_telemetry.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / rabbit_telemetry.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / redis_telemetry.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / confluent.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / confluent_asgi.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / kafka.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / kafka_asgi.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / mqtt.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / mqtt_asgi.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / nats.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / nats_asgi.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / rabbit.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / rabbit_asgi.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / redis.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / redis_asgi.py |
(no function) |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / confluent / delay_equal.py |
handle |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / confluent / delay_equal.py |
test |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / kafka / delay_equal.py |
handle |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / kafka / delay_equal.py |
test |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / nats / delay_equal.py |
handle |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / nats / delay_equal.py |
test |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / rabbit / delay_equal.py |
handle |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / rabbit / delay_equal.py |
test |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / redis / delay_equal.py |
handle |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / redis / delay_equal.py |
test |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / dynamic.py |
main |
|
0% |
6 |
6 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / dynamic.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / dynamic_iter.py |
main |
|
0% |
5 |
5 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / dynamic_iter.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_fields.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_fields.py |
(no function) |
|
0% |
4 |
4 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_struct.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_struct.py |
(no function) |
|
0% |
7 |
7 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic.py |
main |
|
0% |
6 |
6 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic_iter.py |
main |
|
0% |
5 |
5 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic_iter.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_fields.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_fields.py |
(no function) |
|
0% |
4 |
4 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_struct.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_struct.py |
(no function) |
|
0% |
7 |
7 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic.py |
main |
|
0% |
6 |
6 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic_iter.py |
main |
|
0% |
5 |
5 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic_iter.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_fields.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_fields.py |
(no function) |
|
0% |
4 |
4 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_struct.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_struct.py |
(no function) |
|
0% |
7 |
7 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic.py |
main |
|
0% |
6 |
6 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic_iter.py |
main |
|
0% |
5 |
5 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic_iter.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_fields.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_fields.py |
(no function) |
|
0% |
4 |
4 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_struct.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_struct.py |
(no function) |
|
0% |
7 |
7 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic.py |
main |
|
0% |
6 |
6 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic_iter.py |
main |
|
0% |
5 |
5 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic_iter.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_fields.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_fields.py |
(no function) |
|
0% |
4 |
4 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_struct.py |
handle |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_struct.py |
(no function) |
|
0% |
7 |
7 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / index / dependencies_annotated.py |
base_dep |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / index / dependencies_annotated.py |
base_handler |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / index / dependencies_annotated.py |
(no function) |
|
0% |
4 |
4 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py |
echo_faststream_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py |
echo_aiogram_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py |
main |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py |
(no function) |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / kafka / security / sasl_oauthbearer.py |
(no function) |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / redis / stream / claiming_manual_ack.py |
handle |
|
67% |
3 |
1 |
2 |
|
100% |
0 |
0 |
|
67% |
| examples / fastapi_integration / testing.py |
broker |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| examples / nats / e07_object_storage.py |
test_send |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / _compat.py |
model_parse |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / _compat.py |
(no function) |
|
58% |
60 |
25 |
91 |
|
50% |
2 |
1 |
|
58% |
| faststream / _internal / application.py |
catch_startup_validation_error |
|
30% |
10 |
7 |
1 |
|
0% |
2 |
0 |
|
25% |
| faststream / _internal / application.py |
StartAbleApplication._add_broker |
|
67% |
6 |
2 |
0 |
|
50% |
2 |
1 |
|
62% |
| faststream / _internal / application.py |
(no function) |
|
94% |
36 |
2 |
29 |
|
100% |
0 |
0 |
|
94% |
| faststream / _internal / basic_types.py |
(no function) |
|
73% |
33 |
9 |
20 |
|
17% |
6 |
1 |
|
64% |
| faststream / _internal / broker / broker.py |
BrokerUsecase.provider |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / broker / pub_base.py |
BrokerPublishMixin.publish_batch |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / broker / registrator.py |
Registrator.insert_middleware |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / docs.py |
gen |
|
0% |
24 |
24 |
3 |
|
17% |
12 |
0 |
|
6% |
| faststream / _internal / cli / docs.py |
_parse_and_serve |
|
0% |
24 |
24 |
4 |
|
0% |
10 |
0 |
|
0% |
| faststream / _internal / cli / main.py |
loop_callback |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / _internal / cli / main.py |
run |
|
38% |
32 |
20 |
3 |
|
43% |
14 |
4 |
|
39% |
| faststream / _internal / cli / main.py |
_run |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / main.py |
_run_imported_app |
|
50% |
16 |
8 |
5 |
|
67% |
6 |
2 |
|
55% |
| faststream / _internal / cli / main.py |
(no function) |
|
80% |
20 |
4 |
42 |
|
50% |
6 |
3 |
|
73% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
UvicornExtraConfig.__init__ |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
UvicornExtraConfig.load |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
UvicornMultiprocess.init_processes |
|
0% |
5 |
5 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
ASGIMultiprocess.__init__ |
|
0% |
5 |
5 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
ASGIMultiprocess.run |
|
0% |
6 |
6 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
(no function) |
|
0% |
10 |
10 |
10 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / basereload.py |
BaseReload.should_restart |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / multiprocess.py |
Multiprocess.restart |
|
0% |
12 |
12 |
2 |
|
0% |
4 |
0 |
|
0% |
| faststream / _internal / cli / utils / errors.py |
draw_startup_errors |
|
0% |
5 |
5 |
2 |
|
0% |
4 |
0 |
|
0% |
| faststream / _internal / cli / utils / errors.py |
draw_startup_errors.draw_error |
|
0% |
4 |
4 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / utils / errors.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / utils / imports.py |
import_from_string |
|
43% |
7 |
4 |
0 |
|
25% |
4 |
1 |
|
36% |
| faststream / _internal / cli / utils / imports.py |
_is_missing_requested_module |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / _internal / cli / utils / imports.py |
_import_object_or_factory |
|
80% |
25 |
5 |
3 |
|
75% |
8 |
2 |
|
79% |
| faststream / _internal / cli / utils / imports.py |
_try_import_app |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / utils / imports.py |
_import_object |
|
50% |
8 |
4 |
7 |
|
100% |
0 |
0 |
|
50% |
| faststream / _internal / cli / utils / logs.py |
get_log_level |
|
71% |
7 |
2 |
0 |
|
83% |
6 |
1 |
|
77% |
| faststream / _internal / cli / utils / logs.py |
_get_json_config |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / utils / logs.py |
_get_yaml_config |
|
0% |
5 |
5 |
2 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / utils / logs.py |
_get_toml_config |
|
0% |
7 |
7 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / cli / utils / logs.py |
_get_log_config |
|
0% |
13 |
13 |
1 |
|
0% |
8 |
0 |
|
0% |
| faststream / _internal / cli / utils / logs.py |
set_log_config |
|
0% |
2 |
2 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / configs / broker.py |
BrokerConfig.insert_middleware |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / configs / broker.py |
ConfigComposition.insert_middleware |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / endpoint / call_wrapper.py |
HandlerCallWrapper.trigger |
|
80% |
10 |
2 |
0 |
|
88% |
8 |
1 |
|
83% |
| faststream / _internal / endpoint / publisher / fake.py |
FakePublisher.publish |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / endpoint / publisher / fake.py |
FakePublisher.request |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / endpoint / publisher / specification.py |
PublisherSpecification.get_payloads |
|
93% |
14 |
1 |
2 |
|
75% |
8 |
2 |
|
86% |
| faststream / _internal / endpoint / subscriber / call_item.py |
HandlerItem.name |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / _internal / endpoint / subscriber / call_item.py |
HandlerItem.description |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / _internal / endpoint / subscriber / call_item.py |
HandlerItem.is_suitable |
|
75% |
8 |
2 |
0 |
|
75% |
4 |
1 |
|
75% |
| faststream / _internal / endpoint / subscriber / specification.py |
SubscriberSpecification.get_payloads |
|
82% |
11 |
2 |
0 |
|
83% |
6 |
1 |
|
82% |
| faststream / _internal / endpoint / subscriber / supervisor.py |
_SupervisorCache._cleanup |
|
92% |
13 |
1 |
0 |
|
90% |
10 |
1 |
|
91% |
| faststream / _internal / endpoint / subscriber / usecase.py |
SubscriberUsecase.consume |
|
73% |
11 |
3 |
1 |
|
50% |
4 |
0 |
|
67% |
| faststream / _internal / endpoint / subscriber / usecase.py |
SubscriberUsecase.process_message |
|
95% |
38 |
2 |
1 |
|
89% |
18 |
2 |
|
93% |
| faststream / _internal / endpoint / subscriber / usecase.py |
SubscriberUsecase.get_log_context |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / fastapi / _compat.py |
(no function) |
|
62% |
34 |
13 |
16 |
|
100% |
0 |
0 |
|
62% |
| faststream / _internal / fastapi / get_dependant.py |
_patch_fastapi_dependent |
|
87% |
23 |
3 |
5 |
|
100% |
8 |
0 |
|
90% |
| faststream / _internal / fastapi / route.py |
wrap_callable_to_fastapi_compatible |
|
93% |
14 |
1 |
0 |
|
88% |
8 |
1 |
|
91% |
| faststream / _internal / fastapi / route.py |
make_fastapi_execution.app |
|
95% |
20 |
1 |
1 |
|
67% |
6 |
2 |
|
88% |
| faststream / _internal / fastapi / router.py |
StreamRouter._wrap_lifespan.start_broker_lifespan |
|
91% |
23 |
2 |
0 |
|
80% |
10 |
2 |
|
88% |
| faststream / _internal / logger / formatter.py |
ColourizedFormatter.formatMessage |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / _internal / logger / logger_proxy.py |
NotSetLoggerObject.log |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / logger / logger_proxy.py |
EmptyLoggerObject.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / logger / logging.py |
ExtendedFilter.filter |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| faststream / _internal / logger / params_storage.py |
ManualLoggerStorage.set_level |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / logger / params_storage.py |
DefaultLoggerStorage._get_logger_ref |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / _internal / logger / params_storage.py |
DefaultLoggerStorage.set_level |
|
50% |
2 |
1 |
1 |
|
100% |
0 |
0 |
|
50% |
| faststream / _internal / parser.py |
DefaultCodec.encode |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset._parser |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset._parser |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset._decoder |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset._decoder |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset.publish |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset.request |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / producer.py |
ProducerUnset.publish_batch |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / proto.py |
NameRequired.__eq__ |
|
75% |
4 |
1 |
1 |
|
50% |
2 |
1 |
|
67% |
| faststream / _internal / utils / functions.py |
FakeContext.__aenter__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / utils / functions.py |
FakeContext.__aexit__ |
|
0% |
2 |
2 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / _internal / utils / nuid.py |
NUID.next |
|
83% |
12 |
2 |
0 |
|
75% |
4 |
1 |
|
81% |
| faststream / _internal / utils / nuid.py |
NUID.reset_sequential |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / _internal / utils / path.py |
compile_path |
|
81% |
26 |
5 |
0 |
|
75% |
8 |
2 |
|
79% |
| faststream / asgi / app.py |
CliRunState.__init__ |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / app.py |
CliRunState.stop |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / app.py |
cast_uvicorn_params |
|
0% |
7 |
7 |
0 |
|
0% |
6 |
0 |
|
0% |
| faststream / asgi / app.py |
AsgiFastStream.mount |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / app.py |
AsgiFastStream.run |
|
0% |
7 |
7 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / asgi / app.py |
AsgiFastStream.exit |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / app.py |
AsgiFastStream.lifespan |
|
75% |
16 |
4 |
1 |
|
100% |
0 |
0 |
|
75% |
| faststream / asgi / app.py |
AsgiFastStream.lifespan.process_exception |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / asgi / factories / asyncapi / docs.py |
make_asyncapi_asgi.docs |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / asgi / factories / asyncapi / try_it_out.py |
TryItOutProcessor.__init__ |
|
75% |
8 |
2 |
0 |
|
75% |
4 |
1 |
|
75% |
| faststream / asgi / factories / asyncapi / try_it_out.py |
TryItOutProcessor.process |
|
90% |
21 |
2 |
0 |
|
75% |
4 |
1 |
|
88% |
| faststream / asgi / factories / asyncapi / try_it_out.py |
make_try_it_out_handler.try_it_out |
|
60% |
5 |
2 |
0 |
|
100% |
0 |
0 |
|
60% |
| faststream / asgi / handlers.py |
HttpHandler.__call__ |
|
67% |
3 |
1 |
12 |
|
100% |
0 |
0 |
|
67% |
| faststream / asgi / handlers.py |
_get_method_not_allowed_response |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / request.py |
AsgiRequest.stream |
|
58% |
19 |
8 |
0 |
|
64% |
14 |
5 |
|
61% |
| faststream / asgi / request.py |
AsgiRequest.body |
|
100% |
4 |
0 |
0 |
|
50% |
2 |
1 |
|
83% |
| faststream / asgi / request.py |
AsgiRequest.json |
|
100% |
4 |
0 |
0 |
|
50% |
2 |
1 |
|
83% |
| faststream / asgi / request.py |
AsgiRequest.query_params |
|
100% |
4 |
0 |
0 |
|
50% |
2 |
1 |
|
83% |
| faststream / asgi / request.py |
AsgiRequest.headers |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / asgi / request.py |
AsgiRequest.method |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / asgi / response.py |
JSONResponse |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / cli.py |
(no function) |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / helpers / admin.py |
AdminService.connect |
|
100% |
2 |
0 |
0 |
|
50% |
2 |
1 |
|
75% |
| faststream / confluent / helpers / admin.py |
AdminService.create_topics |
|
92% |
12 |
1 |
0 |
|
75% |
4 |
1 |
|
88% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer._poll_loop |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer.stop |
|
100% |
5 |
0 |
0 |
|
50% |
4 |
2 |
|
78% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer.send |
|
86% |
21 |
3 |
0 |
|
70% |
10 |
3 |
|
81% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer.send.ack_callback |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / confluent / helpers / client.py |
AsyncConfluentProducer.ping |
|
57% |
7 |
3 |
0 |
|
50% |
2 |
1 |
|
56% |
| faststream / confluent / helpers / client.py |
AsyncConfluentConsumer.start |
|
71% |
17 |
5 |
2 |
|
67% |
12 |
4 |
|
69% |
| faststream / confluent / helpers / client.py |
BatchBuilder.append |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / confluent / helpers / config.py |
ConfluentFastConfig.__init__ |
|
80% |
10 |
2 |
1 |
|
50% |
4 |
2 |
|
71% |
| faststream / confluent / helpers / config.py |
_to_confluent |
|
100% |
8 |
0 |
0 |
|
83% |
6 |
1 |
|
93% |
| faststream / confluent / opentelemetry / provider.py |
BaseConfluentTelemetrySettingsProvider.get_publish_attrs_from_cmd |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / confluent / opentelemetry / provider.py |
ConfluentTelemetrySettingsProvider.get_consume_attrs_from_message |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / confluent / parser.py |
_parse_msg_headers |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducer.disconnect |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducer.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducer.request |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducerImpl.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / producer.py |
AsyncConfluentFastProducerImpl.publish_batch |
|
89% |
9 |
1 |
0 |
|
75% |
4 |
1 |
|
85% |
| faststream / confluent / publisher / state.py |
EmptyProducerState.producer |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / state.py |
EmptyProducerState.ping |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / state.py |
EmptyProducerState.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / state.py |
RealProducer.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / publisher / usecase.py |
LogicPublisher.flush |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / response.py |
KafkaPublishCommand.headers_to_publish |
|
100% |
6 |
0 |
0 |
|
75% |
4 |
1 |
|
90% |
| faststream / confluent / schemas / partition.py |
TopicPartition.to_confluent |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / confluent / security.py |
parse_security |
|
94% |
18 |
1 |
1 |
|
94% |
16 |
1 |
|
94% |
| faststream / confluent / subscriber / specification.py |
KafkaSubscriberSpecification.name |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / confluent / subscriber / usecase.py |
LogicSubscriber.__aiter__ |
|
90% |
10 |
1 |
0 |
|
50% |
2 |
1 |
|
83% |
| faststream / confluent / testing.py |
TestKafkaBroker.create_publisher_fake_subscriber |
|
87% |
15 |
2 |
0 |
|
88% |
8 |
1 |
|
87% |
| faststream / confluent / testing.py |
FakeProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / testing.py |
FakeProducer.ping |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / testing.py |
FakeProducer.publish_batch |
|
67% |
6 |
2 |
0 |
|
50% |
6 |
1 |
|
58% |
| faststream / confluent / testing.py |
MockConfluentMessage.__init__ |
|
90% |
10 |
1 |
0 |
|
50% |
2 |
1 |
|
83% |
| faststream / confluent / testing.py |
MockConfluentMessage.len |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / testing.py |
MockConfluentMessage.error |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / testing.py |
MockConfluentMessage.key |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / testing.py |
_fake_connection |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / exceptions.py |
StopApplication.__str__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / exceptions.py |
StartupValidationError.__init__ |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / exceptions.py |
StartupValidationError.__str__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / exceptions.py |
ContextError.__str__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / configs / broker.py |
KafkaBrokerConfig.admin_client |
|
50% |
4 |
2 |
0 |
|
50% |
2 |
1 |
|
50% |
| faststream / kafka / exceptions.py |
BatchBufferOverflowException.__str__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / helpers / rebalance_listener.py |
make_logging_listener |
|
83% |
6 |
1 |
0 |
|
75% |
4 |
1 |
|
80% |
| faststream / kafka / helpers / rebalance_listener.py |
_LoggingListener.on_partitions_assigned |
|
60% |
5 |
2 |
2 |
|
50% |
2 |
1 |
|
57% |
| faststream / kafka / message.py |
KafkaAckableMessage.nack |
|
100% |
5 |
0 |
0 |
|
50% |
2 |
1 |
|
86% |
| faststream / kafka / opentelemetry / provider.py |
BaseKafkaTelemetrySettingsProvider.get_publish_attrs_from_cmd |
|
67% |
6 |
2 |
0 |
|
50% |
4 |
2 |
|
60% |
| faststream / kafka / opentelemetry / provider.py |
KafkaTelemetrySettingsProvider.get_consume_attrs_from_message |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducer.closed |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducer.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducer.request |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducerImpl.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducerImpl.closed |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducerImpl.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / producer.py |
AioKafkaFastProducerImpl.publish_batch |
|
93% |
14 |
1 |
0 |
|
88% |
8 |
1 |
|
91% |
| faststream / kafka / publisher / producer.py |
FakeAioKafkaFastProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
EmptyProducerState.producer |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
EmptyProducerState.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
RealProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
RealProducer.closed |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / state.py |
RealProducer.flush |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / publisher / usecase.py |
LogicPublisher.flush |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / response.py |
KafkaPublishCommand.headers_to_publish |
|
100% |
6 |
0 |
0 |
|
75% |
4 |
1 |
|
90% |
| faststream / kafka / security.py |
parse_security |
|
93% |
15 |
1 |
1 |
|
93% |
14 |
1 |
|
93% |
| faststream / kafka / subscriber / specification.py |
KafkaSubscriberSpecification.name |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / kafka / subscriber / usecase.py |
LogicSubscriber.start |
|
100% |
10 |
0 |
1 |
|
75% |
4 |
1 |
|
93% |
| faststream / kafka / subscriber / usecase.py |
LogicSubscriber.__aiter__ |
|
100% |
7 |
0 |
0 |
|
50% |
2 |
1 |
|
89% |
| faststream / kafka / subscriber / usecase.py |
LogicSubscriber._run_consume_loop |
|
65% |
17 |
6 |
2 |
|
50% |
6 |
1 |
|
61% |
| faststream / kafka / subscriber / usecase.py |
ConcurrentBetweenPartitionsSubscriber.start |
|
83% |
12 |
2 |
1 |
|
67% |
6 |
2 |
|
78% |
| faststream / kafka / subscriber / usecase.py |
ConcurrentBetweenPartitionsSubscriber.stop |
|
100% |
6 |
0 |
0 |
|
75% |
4 |
1 |
|
90% |
| faststream / kafka / testing.py |
TestKafkaBroker.create_publisher_fake_subscriber |
|
87% |
15 |
2 |
0 |
|
88% |
8 |
1 |
|
87% |
| faststream / kafka / testing.py |
FakeProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / testing.py |
FakeProducer.closed |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / kafka / testing.py |
FakeProducer.publish_batch |
|
67% |
6 |
2 |
0 |
|
50% |
6 |
1 |
|
58% |
| faststream / kafka / testing.py |
_fake_connection |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / message / message.py |
StreamMessage.clear_cache |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / message / message.py |
StreamMessage.nack |
|
100% |
2 |
0 |
0 |
|
50% |
2 |
1 |
|
75% |
| faststream / middlewares / acknowledgement / middleware.py |
_AcknowledgementMiddleware.consume_scope |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / middlewares / acknowledgement / middleware.py |
_AcknowledgementMiddleware.__aexit__ |
|
95% |
19 |
1 |
0 |
|
89% |
18 |
2 |
|
92% |
| faststream / middlewares / acknowledgement / middleware.py |
_AcknowledgementMiddleware.__nack |
|
75% |
4 |
1 |
2 |
|
50% |
2 |
1 |
|
67% |
| faststream / middlewares / exception.py |
_BaseExceptionMiddleware.after_processed |
|
92% |
12 |
1 |
0 |
|
88% |
8 |
1 |
|
90% |
| faststream / middlewares / logging.py |
_LoggingMiddleware.__aexit__ |
|
100% |
6 |
0 |
3 |
|
50% |
2 |
1 |
|
88% |
| faststream / mqtt / broker / broker.py |
MQTTBroker.ping |
|
57% |
7 |
3 |
0 |
|
50% |
2 |
1 |
|
56% |
| faststream / mqtt / broker / config.py |
MQTTBrokerConfig.client |
|
50% |
4 |
2 |
0 |
|
50% |
2 |
1 |
|
50% |
| faststream / mqtt / broker / config.py |
MQTTBrokerConfig.insert_middleware |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / broker / logging.py |
MQTTParamsStorage.get_logger |
|
100% |
4 |
0 |
1 |
|
50% |
2 |
1 |
|
83% |
| faststream / mqtt / broker / registrator.py |
MQTTRegistrator.include_router |
|
67% |
6 |
2 |
0 |
|
75% |
4 |
1 |
|
70% |
| faststream / mqtt / message.py |
MQTTMessage.ack |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / mqtt / parser.py |
MQTTParserV311.decode_message |
|
86% |
7 |
1 |
0 |
|
100% |
0 |
0 |
|
86% |
| faststream / mqtt / parser.py |
MQTTParserV5.parse_message |
|
100% |
12 |
0 |
0 |
|
50% |
4 |
2 |
|
88% |
| faststream / mqtt / publisher / producer.py |
ZmqttBaseProducer._connected_client |
|
50% |
4 |
2 |
0 |
|
50% |
2 |
1 |
|
50% |
| faststream / mqtt / publisher / producer.py |
ZmqttBaseProducer.publish_batch |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / publisher / producer.py |
ZmqttProducerV311.request |
|
30% |
10 |
7 |
0 |
|
50% |
2 |
1 |
|
33% |
| faststream / mqtt / publisher / producer.py |
ZmqttFakeProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / response.py |
MQTTResponse.__init__ |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / response.py |
MQTTResponse.as_publish_command |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / response.py |
MQTTPublishCommand.from_cmd |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / mqtt / security.py |
parse_security |
|
29% |
7 |
5 |
1 |
|
17% |
6 |
1 |
|
23% |
| faststream / mqtt / subscriber / factory.py |
create_subscriber |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / mqtt / subscriber / specification.py |
MQTTSubscriberSpecification.topic |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / mqtt / subscriber / usecase.py |
MQTTBaseSubscriber.__init__ |
|
92% |
12 |
1 |
0 |
|
75% |
4 |
1 |
|
88% |
| faststream / mqtt / subscriber / usecase.py |
MQTTBaseSubscriber.get_one |
|
100% |
11 |
0 |
0 |
|
50% |
2 |
1 |
|
92% |
| faststream / mqtt / subscriber / usecase.py |
MQTTBaseSubscriber.__aiter__ |
|
100% |
8 |
0 |
0 |
|
50% |
4 |
2 |
|
83% |
| faststream / mqtt / subscriber / usecase.py |
MQTTConcurrentSubscriber.start |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / subscriber / usecase.py |
MQTTConcurrentSubscriber._consume_loop |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / mqtt / testing.py |
_BlockingSubscription.__aiter__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / testing.py |
_BlockingSubscription.__anext__ |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / mqtt / testing.py |
FakeProducer.publish |
|
92% |
12 |
1 |
0 |
|
88% |
8 |
1 |
|
90% |
| faststream / mqtt / testing.py |
FakeProducer.request |
|
88% |
8 |
1 |
0 |
|
75% |
4 |
1 |
|
83% |
| faststream / nats / broker / broker.py |
NatsBroker.__init__ |
|
90% |
10 |
1 |
1 |
|
75% |
4 |
1 |
|
86% |
| faststream / nats / broker / broker.py |
NatsBroker._log_connection_broken.wrapper |
|
0% |
3 |
3 |
1 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / broker / broker.py |
NatsBroker._log_reconnected.wrapper |
|
0% |
3 |
3 |
1 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / broker / broker.py |
NatsBroker.ping |
|
64% |
11 |
4 |
0 |
|
50% |
6 |
3 |
|
59% |
| faststream / nats / broker / logging.py |
NatsParamsStorage.get_logger |
|
100% |
4 |
0 |
1 |
|
50% |
2 |
1 |
|
83% |
| faststream / nats / broker / state.py |
BrokerState.connection |
|
50% |
4 |
2 |
0 |
|
50% |
2 |
1 |
|
50% |
| faststream / nats / broker / state.py |
BrokerState.stream |
|
50% |
4 |
2 |
0 |
|
50% |
2 |
1 |
|
50% |
| faststream / nats / helpers / bucket_declarer.py |
KVBucketDeclarer.create_key_value |
|
83% |
6 |
1 |
0 |
|
75% |
4 |
1 |
|
80% |
| faststream / nats / helpers / obj_storage_declarer.py |
OSBucketDeclarer.create_object_store |
|
83% |
6 |
1 |
0 |
|
75% |
4 |
1 |
|
80% |
| faststream / nats / helpers / state.py |
EmptyConnectionState.connection |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / helpers / state.py |
EmptyConnectionState.connection |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / helpers / stream_builder.py |
StreamBuilder.__contains__ |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / helpers / stream_builder.py |
StreamBuilder.get |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / nats / message.py |
NatsMessage.ack_sync |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / nats / message.py |
NatsMessage.reject |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / nats / message.py |
NatsMessage.in_progress |
|
0% |
2 |
2 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / message.py |
NatsBatchMessage.nack |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / message.py |
NatsBatchMessage.reject |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / message.py |
NatsBatchMessage.in_progress |
|
0% |
2 |
2 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / parser.py |
NatsParser.parse_message |
|
100% |
5 |
0 |
0 |
|
50% |
2 |
1 |
|
86% |
| faststream / nats / parser.py |
BatchParser.parse_batch |
|
90% |
10 |
1 |
0 |
|
75% |
4 |
1 |
|
86% |
| faststream / nats / publisher / producer.py |
NatsFastProducer.publish_batch |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / publisher / producer.py |
FakeNatsFastProducer.publish_batch |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / publisher / usecase.py |
LogicPublisher.clear_subject |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / publisher / usecase.py |
LogicPublisher.publish |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / nats / publisher / usecase.py |
LogicPublisher._publish |
|
73% |
11 |
3 |
0 |
|
50% |
4 |
2 |
|
67% |
| faststream / nats / response.py |
NatsPublishCommand.headers_to_publish |
|
89% |
9 |
1 |
0 |
|
67% |
6 |
2 |
|
80% |
| faststream / nats / schemas / obj_watch.py |
ObjWatch.validate |
|
80% |
5 |
1 |
0 |
|
75% |
4 |
1 |
|
78% |
| faststream / nats / schemas / pull_sub.py |
PullSub.validate |
|
80% |
5 |
1 |
0 |
|
75% |
4 |
1 |
|
78% |
| faststream / nats / security.py |
parse_security |
|
29% |
7 |
5 |
1 |
|
17% |
6 |
1 |
|
23% |
| faststream / nats / security.py |
_parse_base_security |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / factory.py |
create_subscriber |
|
88% |
43 |
5 |
0 |
|
73% |
30 |
6 |
|
82% |
| faststream / nats / subscriber / factory.py |
_validate_input_for_misconfigure |
|
54% |
63 |
29 |
0 |
|
60% |
62 |
25 |
|
57% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState.client |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState.js |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState.kv_declarer |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState.kv_declarer |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState.os_declarer |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
EmptySubscriberState.os_declarer |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
ConnectedSubscriberState.__init__ |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
ConnectedSubscriberState.client |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
ConnectedSubscriberState.js |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / state.py |
(no function) |
|
0% |
22 |
22 |
10 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
CoreSubscriber.get_one |
|
92% |
12 |
1 |
0 |
|
50% |
2 |
1 |
|
86% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
CoreSubscriber.__aiter__ |
|
89% |
9 |
1 |
0 |
|
50% |
4 |
2 |
|
77% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
CoreSubscriber._create_subscription |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
ConcurrentCoreSubscriber._create_subscription |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
KeyValueWatchSubscriber.get_one |
|
92% |
13 |
1 |
0 |
|
75% |
4 |
1 |
|
88% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
KeyValueWatchSubscriber.__aiter__ |
|
88% |
17 |
2 |
0 |
|
67% |
6 |
2 |
|
83% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
KeyValueWatchSubscriber._create_subscription |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
KeyValueWatchSubscriber.__consume_watch |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
KeyValueWatchSubscriber._make_response_publisher |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
ObjStoreWatchSubscriber.get_one |
|
93% |
14 |
1 |
0 |
|
75% |
4 |
1 |
|
89% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
ObjStoreWatchSubscriber.__aiter__ |
|
89% |
18 |
2 |
0 |
|
67% |
6 |
2 |
|
83% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
ObjStoreWatchSubscriber._create_subscription |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
ObjStoreWatchSubscriber.__consume_watch |
|
100% |
9 |
0 |
0 |
|
75% |
4 |
1 |
|
92% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
ObjStoreWatchSubscriber._make_response_publisher |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / stream_basic.py |
StreamSubscriber.get_one |
|
100% |
14 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| faststream / nats / subscriber / usecases / stream_basic.py |
StreamSubscriber.__aiter__ |
|
100% |
12 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
PullStreamSubscriber._create_subscription |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
PullStreamSubscriber._consume_pull |
|
100% |
9 |
0 |
0 |
|
83% |
6 |
1 |
|
93% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
ConcurrentPullStreamSubscriber._create_subscription |
|
0% |
5 |
5 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
BatchPullStreamSubscriber.get_one |
|
91% |
11 |
1 |
0 |
|
50% |
2 |
1 |
|
85% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
BatchPullStreamSubscriber.__aiter__ |
|
89% |
9 |
1 |
0 |
|
50% |
2 |
1 |
|
82% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
BatchPullStreamSubscriber._create_subscription |
|
75% |
4 |
1 |
0 |
|
50% |
2 |
1 |
|
67% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
BatchPullStreamSubscriber._consume_pull |
|
100% |
6 |
0 |
0 |
|
75% |
4 |
1 |
|
90% |
| faststream / nats / subscriber / usecases / stream_push_subscriber.py |
PushStreamSubscriber._create_subscription |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / nats / subscriber / usecases / stream_push_subscriber.py |
ConcurrentPushStreamSubscriber._create_subscription |
|
0% |
4 |
4 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / nats / testing.py |
_is_handler_matches |
|
91% |
11 |
1 |
0 |
|
92% |
12 |
1 |
|
91% |
| faststream / opentelemetry / baggage.py |
Baggage.to_headers |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| faststream / opentelemetry / middleware.py |
BaseTelemetryMiddleware.publish_scope |
|
91% |
34 |
3 |
1 |
|
90% |
10 |
1 |
|
91% |
| faststream / opentelemetry / middleware.py |
_get_meter |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / prometheus / middleware.py |
PrometheusMiddleware.__init__ |
|
100% |
11 |
0 |
0 |
|
83% |
6 |
1 |
|
94% |
| faststream / rabbit / broker / broker.py |
RabbitBroker._connect |
|
100% |
5 |
0 |
0 |
|
50% |
2 |
1 |
|
86% |
| faststream / rabbit / broker / broker.py |
RabbitBroker.stop |
|
100% |
9 |
0 |
0 |
|
83% |
6 |
1 |
|
93% |
| faststream / rabbit / broker / broker.py |
RabbitBroker.ping |
|
64% |
11 |
4 |
0 |
|
50% |
6 |
3 |
|
59% |
| faststream / rabbit / broker / logging.py |
RabbitParamsStorage.get_logger |
|
100% |
4 |
0 |
1 |
|
50% |
2 |
1 |
|
83% |
| faststream / rabbit / helpers / declarer.py |
RabbitDeclarerImpl.declare_queue |
|
100% |
5 |
0 |
1 |
|
75% |
4 |
1 |
|
89% |
| faststream / rabbit / helpers / state.py |
EmptyConnectionState.connection |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / message.py |
RabbitMessage.nack |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / rabbit / publisher / fake.py |
RabbitFakePublisher.patch_command |
|
100% |
7 |
0 |
0 |
|
50% |
2 |
1 |
|
89% |
| faststream / rabbit / publisher / producer.py |
LockUnset.lock |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / publisher / producer.py |
AioPikaFastProducer.publish_batch |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / publisher / producer.py |
FakeAioPikaFastProducer.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / rabbit / publisher / usecase.py |
RabbitPublisher.message_options |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / rabbit / publisher / usecase.py |
RabbitPublisher.start |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / rabbit / publisher / usecase.py |
RabbitPublisher.publish |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / rabbit / publisher / usecase.py |
RabbitPublisher.request |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / rabbit / response.py |
RabbitPublishCommand.exchange |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / rabbit / schemas / queue.py |
RabbitQueue.__init__ |
|
85% |
20 |
3 |
1 |
|
75% |
8 |
2 |
|
82% |
| faststream / rabbit / security.py |
parse_security |
|
86% |
7 |
1 |
1 |
|
83% |
6 |
1 |
|
85% |
| faststream / rabbit / subscriber / usecase.py |
RabbitSubscriber.__aiter__ |
|
100% |
9 |
0 |
0 |
|
50% |
2 |
1 |
|
91% |
| faststream / rabbit / testing.py |
_is_handler_matches |
|
96% |
24 |
1 |
2 |
|
94% |
16 |
1 |
|
95% |
| faststream / rabbit / testing.py |
apply_pattern |
|
92% |
24 |
2 |
0 |
|
90% |
20 |
2 |
|
91% |
| faststream / rabbit / types.py |
(no function) |
|
0% |
1 |
1 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / broker / broker.py |
RedisBroker.ping |
|
85% |
13 |
2 |
1 |
|
50% |
6 |
3 |
|
74% |
| faststream / redis / configs / broker.py |
RedisRouterConfig.connection |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / configs / state.py |
ConnectionState.client |
|
50% |
4 |
2 |
0 |
|
50% |
2 |
1 |
|
50% |
| faststream / redis / configs / state.py |
ConnectionState.__bool__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / message.py |
_RedisStreamMessageMixin.reject |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / message.py |
_RedisStreamMessageMixin.delete |
|
100% |
4 |
0 |
0 |
|
50% |
2 |
1 |
|
83% |
| faststream / redis / parser / binary.py |
BinaryWriter.write_string |
|
80% |
5 |
1 |
0 |
|
50% |
2 |
1 |
|
71% |
| faststream / redis / publisher / factory.py |
create_publisher |
|
93% |
15 |
1 |
0 |
|
88% |
8 |
1 |
|
91% |
| faststream / redis / publisher / producer.py |
RedisFastProducer.request |
|
94% |
16 |
1 |
0 |
|
50% |
2 |
1 |
|
89% |
| faststream / redis / publisher / producer.py |
RedisFastProducer.__publish |
|
88% |
8 |
1 |
1 |
|
83% |
6 |
1 |
|
86% |
| faststream / redis / publisher / specification.py |
ListPublisherSpecification.name |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / redis / publisher / specification.py |
StreamPublisherSpecification.name |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / redis / publisher / usecase.py |
ListPublisher.request |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / publisher / usecase.py |
ListBatchPublisher.publish |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / publisher / usecase.py |
StreamPublisher.request |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / schemas / list_sub.py |
ListSub.records |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / schemas / proto.py |
validate_options |
|
33% |
9 |
6 |
0 |
|
50% |
6 |
3 |
|
40% |
| faststream / redis / schemas / stream_sub.py |
StreamSub.__init__ |
|
91% |
23 |
2 |
0 |
|
86% |
14 |
2 |
|
89% |
| faststream / redis / security.py |
parse_security |
|
86% |
7 |
1 |
1 |
|
83% |
6 |
1 |
|
85% |
| faststream / redis / subscriber / factory.py |
create_subscriber |
|
96% |
25 |
1 |
0 |
|
94% |
16 |
1 |
|
95% |
| faststream / redis / subscriber / factory.py |
_validate_input_for_misconfigure |
|
56% |
9 |
4 |
0 |
|
62% |
8 |
3 |
|
59% |
| faststream / redis / subscriber / specification.py |
ListSubscriberSpecification.name |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / redis / subscriber / specification.py |
StreamSubscriberSpecification.name |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / redis / subscriber / usecases / basic.py |
LogicSubscriber._consume |
|
64% |
14 |
5 |
0 |
|
62% |
8 |
1 |
|
64% |
| faststream / redis / subscriber / usecases / basic.py |
ConcurrentSubscriber.__init__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / subscriber / usecases / basic.py |
ConcurrentSubscriber.start |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / subscriber / usecases / basic.py |
ConcurrentSubscriber.consume_one |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / subscriber / usecases / channel_subscriber.py |
ChannelSubscriber.start |
|
86% |
7 |
1 |
0 |
|
75% |
4 |
1 |
|
82% |
| faststream / redis / subscriber / usecases / channel_subscriber.py |
ChannelSubscriber.__aiter__ |
|
93% |
15 |
1 |
0 |
|
75% |
4 |
1 |
|
89% |
| faststream / redis / subscriber / usecases / list_subscriber.py |
_ListHandlerMixin._consume |
|
100% |
3 |
0 |
0 |
|
50% |
2 |
1 |
|
80% |
| faststream / redis / subscriber / usecases / list_subscriber.py |
_ListHandlerMixin.__aiter__ |
|
87% |
15 |
2 |
0 |
|
50% |
4 |
2 |
|
79% |
| faststream / redis / subscriber / usecases / stream_subscriber.py |
_StreamHandlerMixin._consume |
|
83% |
12 |
2 |
2 |
|
67% |
6 |
2 |
|
78% |
| faststream / redis / subscriber / usecases / stream_subscriber.py |
_StreamHandlerMixin.get_one |
|
83% |
24 |
4 |
0 |
|
70% |
10 |
1 |
|
79% |
| faststream / redis / subscriber / usecases / stream_subscriber.py |
_StreamHandlerMixin.__aiter__ |
|
77% |
26 |
6 |
0 |
|
50% |
10 |
3 |
|
69% |
| faststream / redis / testing.py |
FakeProducer.publish_batch |
|
100% |
10 |
0 |
0 |
|
83% |
6 |
1 |
|
94% |
| faststream / redis / testing.py |
_make_destination_kwargs |
|
90% |
10 |
1 |
0 |
|
88% |
8 |
1 |
|
89% |
| faststream / response / response.py |
Response.get_publish_key |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / response / response.py |
key_for_index |
|
86% |
7 |
1 |
0 |
|
50% |
2 |
1 |
|
78% |
| faststream / specification / asyncapi / factory.py |
AsyncAPI.to_specification |
|
80% |
5 |
1 |
3 |
|
100% |
0 |
0 |
|
80% |
| faststream / specification / asyncapi / message.py |
get_response_schema |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / message.py |
get_model_schema |
|
97% |
39 |
1 |
0 |
|
96% |
24 |
1 |
|
97% |
| faststream / specification / asyncapi / site.py |
get_asyncapi_html |
|
67% |
6 |
2 |
0 |
|
50% |
2 |
1 |
|
62% |
| faststream / specification / asyncapi / site.py |
serve_app |
|
0% |
1 |
1 |
2 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / site.py |
_Handler.__init__ |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / site.py |
_Handler.get_query_params |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / site.py |
_Handler.do_GET |
|
0% |
9 |
9 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / site.py |
_str_to_bool |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / generate.py |
get_broker_channels |
|
83% |
12 |
2 |
0 |
|
83% |
12 |
2 |
|
83% |
| faststream / specification / asyncapi / v2_6_0 / generate.py |
_resolve_msg_payloads |
|
97% |
37 |
1 |
1 |
|
91% |
22 |
2 |
|
95% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
Queue.from_spec |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
Exchange.from_spec |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
ChannelBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
ChannelBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / operation.py |
OperationBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / operation.py |
OperationBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / channel.py |
ChannelBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / channel.py |
ChannelBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / operation.py |
OperationBinding.from_sub |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / operation.py |
OperationBinding.from_pub |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / channel.py |
ChannelBinding.from_sub |
|
73% |
15 |
4 |
0 |
|
71% |
14 |
2 |
|
72% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / channel.py |
ChannelBinding.from_pub |
|
73% |
15 |
4 |
0 |
|
71% |
14 |
2 |
|
72% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / channel.py |
(no function) |
|
87% |
15 |
2 |
14 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / operation.py |
OperationBinding.from_sub |
|
47% |
15 |
8 |
0 |
|
43% |
14 |
2 |
|
45% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / operation.py |
OperationBinding.from_pub |
|
47% |
15 |
8 |
0 |
|
43% |
14 |
2 |
|
45% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / operation.py |
(no function) |
|
88% |
16 |
2 |
14 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / channel.py |
ChannelBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / channel.py |
ChannelBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / operation.py |
OperationBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / operation.py |
OperationBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / channel.py |
ChannelBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / channel.py |
ChannelBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / operation.py |
OperationBinding.from_sub |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / operation.py |
OperationBinding.from_pub |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / channel.py |
ChannelBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / channel.py |
ChannelBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / operation.py |
OperationBinding.from_sub |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / operation.py |
OperationBinding.from_pub |
|
0% |
3 |
3 |
0 |
|
0% |
2 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / channel.py |
ChannelBinding.from_pub |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / channel.py |
ChannelBinding.from_sub |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / operation.py |
OperationBinding.from_pub |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / operation.py |
OperationBinding.from_sub |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| faststream / specification / asyncapi / v2_6_0 / schema / channels.py |
(no function) |
|
86% |
14 |
2 |
6 |
|
50% |
2 |
1 |
|
81% |
| faststream / specification / asyncapi / v2_6_0 / schema / components.py |
(no function) |
|
75% |
8 |
2 |
4 |
|
50% |
2 |
1 |
|
70% |
| faststream / specification / asyncapi / v2_6_0 / schema / contact.py |
(no function) |
|
80% |
10 |
2 |
15 |
|
50% |
2 |
1 |
|
75% |
| faststream / specification / asyncapi / v2_6_0 / schema / docs.py |
(no function) |
|
78% |
9 |
2 |
15 |
|
50% |
2 |
1 |
|
73% |
| faststream / specification / asyncapi / v2_6_0 / schema / license.py |
(no function) |
|
78% |
9 |
2 |
15 |
|
50% |
2 |
1 |
|
73% |
| faststream / specification / asyncapi / v2_6_0 / schema / message.py |
(no function) |
|
83% |
23 |
4 |
6 |
|
50% |
4 |
2 |
|
78% |
| faststream / specification / asyncapi / v2_6_0 / schema / operations.py |
(no function) |
|
88% |
16 |
2 |
9 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v2_6_0 / schema / servers.py |
(no function) |
|
82% |
22 |
4 |
5 |
|
50% |
4 |
2 |
|
77% |
| faststream / specification / asyncapi / v2_6_0 / schema / tag.py |
(no function) |
|
80% |
10 |
2 |
14 |
|
50% |
2 |
1 |
|
75% |
| faststream / specification / asyncapi / v3_0_0 / generate.py |
get_broker_channels |
|
86% |
22 |
3 |
0 |
|
79% |
14 |
3 |
|
83% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / channel.py |
ChannelBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / channel.py |
ChannelBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / operation.py |
OperationBinding.from_sub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / operation.py |
OperationBinding.from_pub |
|
67% |
3 |
1 |
0 |
|
50% |
2 |
1 |
|
60% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / channel.py |
ChannelBinding.from_sub |
|
73% |
15 |
4 |
0 |
|
71% |
14 |
2 |
|
72% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / channel.py |
ChannelBinding.from_pub |
|
73% |
15 |
4 |
0 |
|
71% |
14 |
2 |
|
72% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / channel.py |
(no function) |
|
87% |
15 |
2 |
5 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / operation.py |
OperationBinding.from_sub |
|
47% |
15 |
8 |
0 |
|
43% |
14 |
2 |
|
45% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / operation.py |
OperationBinding.from_pub |
|
47% |
15 |
8 |
0 |
|
43% |
14 |
2 |
|
45% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / operation.py |
(no function) |
|
88% |
16 |
2 |
5 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v3_0_0 / schema / channels.py |
(no function) |
|
86% |
14 |
2 |
7 |
|
50% |
2 |
1 |
|
81% |
| faststream / specification / asyncapi / v3_0_0 / schema / components.py |
(no function) |
|
75% |
8 |
2 |
4 |
|
50% |
2 |
1 |
|
70% |
| faststream / specification / asyncapi / v3_0_0 / schema / operations.py |
(no function) |
|
90% |
20 |
2 |
10 |
|
50% |
2 |
1 |
|
86% |
| faststream / specification / asyncapi / v3_0_0 / schema / servers.py |
(no function) |
|
87% |
15 |
2 |
5 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / base / info.py |
(no function) |
|
75% |
8 |
2 |
2 |
|
50% |
2 |
1 |
|
70% |
| tests / asgi / testcase.py |
AsgiTestcase.test_validation_error_handled.some_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / basic.py |
(no function) |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / v2_6_0 / arguments.py |
FastAPICompatible.test_pydantic_model_with_example |
|
85% |
13 |
2 |
1 |
|
75% |
4 |
1 |
|
82% |
| tests / asyncapi / base / v2_6_0 / arguments.py |
FastAPICompatible.test_ignores_depends.dep |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / v2_6_0 / arguments.py |
FastAPICompatible.test_ignores_depends.dep2 |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / v2_6_0 / arguments.py |
FastAPICompatible.test_discriminator |
|
100% |
16 |
0 |
3 |
|
75% |
4 |
1 |
|
95% |
| tests / asyncapi / base / v3_0_0 / arguments.py |
FastAPICompatible.test_pydantic_model_with_example |
|
85% |
13 |
2 |
1 |
|
75% |
4 |
1 |
|
82% |
| tests / asyncapi / base / v3_0_0 / arguments.py |
FastAPICompatible.test_ignores_depends.dep |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / v3_0_0 / arguments.py |
FastAPICompatible.test_ignores_depends.dep2 |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / confluent / v2_6_0 / base.py |
AsyncAPI26Mixin.get_schema |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / confluent / v3_0_0 / base.py |
AsyncAPI30Mixin.get_schema |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / basic.py |
BaseTestcaseConfig.patch_broker |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / codec.py |
CodecTestcase.test_codec_and_decoder_conflict_raises.my_decoder |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / connection.py |
BrokerConnectionTestcase.get_broker_args |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / consume.py |
BrokerRealConsumeTestcase.test_iteration.consume |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| tests / brokers / base / fastapi.py |
FastAPILocalTestcase.test_depends_from_fastdepends_default |
|
88% |
8 |
1 |
2 |
|
100% |
0 |
0 |
|
88% |
| tests / brokers / base / fastapi.py |
FastAPILocalTestcase.test_depends_from_fastdepends_annotated |
|
88% |
8 |
1 |
2 |
|
100% |
0 |
0 |
|
88% |
| tests / brokers / base / fastapi.py |
FastAPILocalTestcase.test_faststream_context |
|
86% |
7 |
1 |
2 |
|
100% |
0 |
0 |
|
86% |
| tests / brokers / base / fastapi.py |
FastAPILocalTestcase.test_faststream_context_annotated |
|
86% |
7 |
1 |
2 |
|
100% |
0 |
0 |
|
86% |
| tests / brokers / base / fastapi.py |
FastAPILocalTestcase.test_nested_router.hello_router2 |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_skip_msg.subscriber2 |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_do_not_catch_skip_msg.value_error_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_reraise.subscriber2 |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_init_handler_same.value_error_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_init_publish_handler_same.value_error_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_decoder_error.subscriber1 |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / middlewares.py |
ExceptionMiddlewareTestcase.test_exception_middleware_mro_resolution.handle_a |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / base / parser.py |
LocalCustomParserTestcase.test_iterator_respect_decoder.iter_messages |
|
100% |
10 |
0 |
0 |
|
50% |
2 |
1 |
|
92% |
| tests / brokers / base / publish.py |
BrokerPublishTestcase.test_no_reply.reply_handler |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / confluent / conftest.py |
router |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / confluent / test_security.py |
patch_aio_consumer_and_producer |
|
0% |
4 |
4 |
1 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / confluent / test_test_client.py |
TestTestclient.test_publisher_without_destination |
|
75% |
8 |
2 |
0 |
|
100% |
0 |
0 |
|
75% |
| tests / brokers / kafka / conftest.py |
router |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / kafka / test_test_client.py |
TestTestclient.test_publisher_without_destination |
|
75% |
8 |
2 |
0 |
|
100% |
0 |
0 |
|
75% |
| tests / brokers / mqtt / conftest.py |
router |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / mqtt / test_consume.py |
TestConsume.test_iteration.consume |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| tests / brokers / mqtt / test_testclient.py |
TestTestclient.get_fake_producer_class |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / nats / test_consume.py |
TestConsume.test_iterator_js |
|
100% |
14 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| tests / brokers / nats / test_consume.py |
TestConsume.test_iterator_pull |
|
100% |
14 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| tests / brokers / nats / test_consume.py |
TestConsume.test_iterator_batch |
|
100% |
14 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| tests / brokers / nats / test_consume.py |
TestConsume.test_iterator_with_filter |
|
100% |
14 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| tests / brokers / nats / test_consume.py |
TestConsume.test_iterator_kv |
|
100% |
16 |
0 |
0 |
|
75% |
4 |
1 |
|
95% |
| tests / brokers / nats / test_consume.py |
TestConsume.test_iterator_os |
|
100% |
17 |
0 |
0 |
|
75% |
4 |
1 |
|
95% |
| tests / brokers / nats / test_test_client.py |
TestTestclient.test_publisher_without_destination |
|
50% |
8 |
4 |
0 |
|
100% |
0 |
0 |
|
50% |
| tests / brokers / rabbit / conftest.py |
router |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / rabbit / test_test_client.py |
TestTestclient.test_publisher_without_destination |
|
62% |
8 |
3 |
0 |
|
100% |
0 |
0 |
|
62% |
| tests / brokers / redis / conftest.py |
router |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / brokers / redis / test_autoclaim.py |
TestAutoClaim.test_iterator_with_min_idle_time |
|
100% |
23 |
0 |
0 |
|
75% |
4 |
1 |
|
96% |
| tests / brokers / redis / test_autoclaim.py |
TestAutoClaim.test_xautoclaim_circular_scanning_with_idle_timeout |
|
100% |
20 |
0 |
12 |
|
75% |
4 |
1 |
|
96% |
| tests / brokers / redis / test_consume.py |
TestConsumeList.test_iterator |
|
100% |
14 |
0 |
0 |
|
75% |
4 |
1 |
|
94% |
| tests / brokers / redis / test_consume.py |
TestConsumeStream.test_iterator.consume |
|
100% |
7 |
0 |
0 |
|
75% |
4 |
1 |
|
91% |
| tests / brokers / redis / test_consume.py |
TestConsumeStream.test_consume_stream_group_deleted |
|
96% |
25 |
1 |
1 |
|
50% |
4 |
2 |
|
90% |
| tests / brokers / redis / test_test_client.py |
TestTestclient.test_publisher_without_destination |
|
57% |
14 |
6 |
0 |
|
100% |
0 |
0 |
|
57% |
| tests / brokers / supervisor / test_supervisor.py |
test_ignore_cancellation_error.cancelled_task |
|
0% |
2 |
2 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / cli / conftest.py |
CLIThread._poll_std |
|
92% |
12 |
1 |
0 |
|
90% |
10 |
1 |
|
91% |
| tests / cli / conftest.py |
CLIThread.wait_for_stderr |
|
91% |
11 |
1 |
0 |
|
88% |
8 |
1 |
|
89% |
| tests / cli / conftest.py |
CLIThread.stop |
|
75% |
8 |
2 |
0 |
|
100% |
0 |
0 |
|
75% |
| tests / cli / conftest.py |
wait_for_startup |
|
88% |
8 |
1 |
0 |
|
83% |
6 |
1 |
|
86% |
| tests / cli / supervisors / test_watchfiles.py |
touch_file |
|
0% |
3 |
3 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / cli / test_asyncapi_docs.py |
test_serve_asyncapi_docs_from_app |
|
86% |
7 |
1 |
1 |
|
100% |
0 |
0 |
|
86% |
| tests / cli / test_asyncapi_docs.py |
test_serve_asyncapi_docs_from_file |
|
86% |
7 |
1 |
1 |
|
100% |
0 |
0 |
|
86% |
| tests / conftest.py |
kafka_ascynapi_project |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / docs / confluent / publish_with_partition_key / test_app.py |
test_keys |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / docs / getting_started / config / test_settings_base_1.py |
test_exists_and_valid |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| tests / docs / kafka / publish_with_partition_key / test_app.py |
test_keys |
|
0% |
4 |
4 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / examples / nats / test_e07_object_storage.py |
test_basic |
|
80% |
15 |
3 |
2 |
|
67% |
6 |
2 |
|
76% |
| tests / marks.py |
(no function) |
|
66% |
29 |
10 |
7 |
|
100% |
0 |
0 |
|
66% |
| tests / opentelemetry / basic.py |
LocalTelemetryTestcase.patch_broker |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |
| tests / prometheus / basic.py |
LocalPrometheusTestcase.test_metrics.handler |
|
100% |
10 |
0 |
0 |
|
88% |
8 |
1 |
|
94% |
| tests / utils / context / test_main.py |
test_context_with_custom_object_implementing_comparison.User.__ne__ |
|
0% |
1 |
1 |
0 |
|
100% |
0 |
0 |
|
0% |