| docs / docs_src / confluent / security / custom_config.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / asyncapi / asyncapi_customization / payload_info.py |
|
86% |
7 |
1 |
5 |
|
100% |
0 |
0 |
|
86% |
| docs / docs_src / getting_started / asyncapi / serve.py |
|
0% |
5 |
5 |
0 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / config / settings_base_1.py |
|
0% |
4 |
4 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / confluent / basic.py |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / kafka / basic.py |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / nats / basic.py |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / rabbit / basic.py |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / lifespan / redis / basic.py |
|
0% |
9 |
9 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / confluent_base_run.py |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / kafka_base_run.py |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / nats_base_run.py |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / rabbit_base_run.py |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / manual_run / redis_base_run.py |
|
0% |
4 |
4 |
5 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / confluent_telemetry.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / kafka_telemetry.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / mqtt_telemetry.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / nats_telemetry.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / rabbit_telemetry.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / opentelemetry / redis_telemetry.py |
|
0% |
2 |
2 |
3 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / confluent.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / confluent_asgi.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / kafka.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / kafka_asgi.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / mqtt.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / mqtt_asgi.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / nats.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / nats_asgi.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / rabbit.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / rabbit_asgi.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / redis.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / prometheus / redis_asgi.py |
|
0% |
3 |
3 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / routers / confluent / delay_equal.py |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / kafka / delay_equal.py |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / nats / delay_equal.py |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / rabbit / delay_equal.py |
|
69% |
13 |
4 |
2 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / routers / redis / delay_equal.py |
|
69% |
13 |
4 |
3 |
|
100% |
0 |
0 |
|
69% |
| docs / docs_src / getting_started / subscription / confluent / dynamic.py |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / dynamic_iter.py |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_fields.py |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / confluent / msgspec_struct.py |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic.py |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / dynamic_iter.py |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_fields.py |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / kafka / msgspec_struct.py |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic.py |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / dynamic_iter.py |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_fields.py |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / nats / msgspec_struct.py |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic.py |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / dynamic_iter.py |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_fields.py |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / rabbit / msgspec_struct.py |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic.py |
|
0% |
7 |
7 |
1 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / dynamic_iter.py |
|
0% |
6 |
6 |
2 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_fields.py |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / getting_started / subscription / redis / msgspec_struct.py |
|
0% |
9 |
9 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / index / dependencies_annotated.py |
|
0% |
6 |
6 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / integrations / no_http_frameworks_integrations / aiogram.py |
|
0% |
14 |
14 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / kafka / security / sasl_oauthbearer.py |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| docs / docs_src / redis / stream / claiming_manual_ack.py |
|
90% |
10 |
1 |
4 |
|
100% |
0 |
0 |
|
90% |
| examples / fastapi_integration / testing.py |
|
86% |
14 |
2 |
5 |
|
100% |
0 |
0 |
|
86% |
| examples / nats / e07_object_storage.py |
|
80% |
10 |
2 |
5 |
|
100% |
0 |
0 |
|
80% |
| faststream / _internal / _compat.py |
|
61% |
66 |
26 |
91 |
|
50% |
2 |
1 |
|
60% |
| faststream / _internal / application.py |
|
90% |
110 |
11 |
38 |
|
86% |
22 |
1 |
|
89% |
| faststream / _internal / basic_types.py |
|
73% |
33 |
9 |
21 |
|
17% |
6 |
1 |
|
64% |
| faststream / _internal / broker / broker.py |
|
98% |
46 |
1 |
25 |
|
100% |
8 |
0 |
|
98% |
| faststream / _internal / broker / pub_base.py |
|
92% |
24 |
2 |
40 |
|
100% |
6 |
0 |
|
93% |
| faststream / _internal / broker / registrator.py |
|
98% |
42 |
1 |
31 |
|
100% |
8 |
0 |
|
98% |
| faststream / _internal / cli / docs.py |
|
8% |
52 |
48 |
87 |
|
9% |
22 |
0 |
|
8% |
| faststream / _internal / cli / main.py |
|
59% |
87 |
36 |
83 |
|
53% |
30 |
10 |
|
57% |
| faststream / _internal / cli / supervisors / asgi_multiprocess.py |
|
0% |
30 |
30 |
10 |
|
0% |
4 |
0 |
|
0% |
| faststream / _internal / cli / supervisors / basereload.py |
|
97% |
36 |
1 |
13 |
|
100% |
4 |
0 |
|
98% |
| faststream / _internal / cli / supervisors / multiprocess.py |
|
57% |
28 |
12 |
14 |
|
33% |
6 |
0 |
|
53% |
| faststream / _internal / cli / utils / errors.py |
|
0% |
10 |
10 |
4 |
|
0% |
4 |
0 |
|
0% |
| faststream / _internal / cli / utils / imports.py |
|
69% |
65 |
20 |
17 |
|
67% |
18 |
4 |
|
69% |
| faststream / _internal / cli / utils / logs.py |
|
48% |
60 |
31 |
21 |
|
36% |
14 |
1 |
|
46% |
| faststream / _internal / configs / broker.py |
|
98% |
97 |
2 |
19 |
|
100% |
18 |
0 |
|
98% |
| faststream / _internal / endpoint / call_wrapper.py |
|
97% |
58 |
2 |
18 |
|
94% |
16 |
1 |
|
96% |
| faststream / _internal / endpoint / publisher / fake.py |
|
85% |
13 |
2 |
19 |
|
100% |
2 |
0 |
|
87% |
| faststream / _internal / endpoint / publisher / specification.py |
|
97% |
30 |
1 |
16 |
|
75% |
8 |
2 |
|
92% |
| faststream / _internal / endpoint / subscriber / call_item.py |
|
93% |
58 |
4 |
37 |
|
85% |
20 |
3 |
|
91% |
| faststream / _internal / endpoint / subscriber / specification.py |
|
93% |
28 |
2 |
18 |
|
83% |
6 |
1 |
|
91% |
| faststream / _internal / endpoint / subscriber / supervisor.py |
|
98% |
43 |
1 |
27 |
|
94% |
16 |
1 |
|
97% |
| faststream / _internal / endpoint / subscriber / usecase.py |
|
95% |
126 |
6 |
104 |
|
89% |
36 |
2 |
|
94% |
| faststream / _internal / fastapi / _compat.py |
|
66% |
38 |
13 |
16 |
|
100% |
0 |
0 |
|
66% |
| faststream / _internal / fastapi / get_dependant.py |
|
90% |
29 |
3 |
83 |
|
100% |
8 |
0 |
|
92% |
| faststream / _internal / fastapi / route.py |
|
97% |
68 |
2 |
25 |
|
85% |
20 |
3 |
|
94% |
| faststream / _internal / fastapi / router.py |
|
98% |
89 |
2 |
109 |
|
90% |
20 |
2 |
|
96% |
| faststream / _internal / logger / formatter.py |
|
100% |
13 |
0 |
3 |
|
75% |
4 |
1 |
|
94% |
| faststream / _internal / logger / logger_proxy.py |
|
85% |
20 |
3 |
18 |
|
100% |
0 |
0 |
|
85% |
| faststream / _internal / logger / logging.py |
|
100% |
29 |
0 |
17 |
|
83% |
6 |
1 |
|
97% |
| faststream / _internal / logger / params_storage.py |
|
89% |
28 |
3 |
21 |
|
75% |
4 |
1 |
|
88% |
| faststream / _internal / parser.py |
|
91% |
11 |
1 |
41 |
|
100% |
0 |
0 |
|
91% |
| faststream / _internal / producer.py |
|
69% |
26 |
8 |
25 |
|
100% |
0 |
0 |
|
69% |
| faststream / _internal / proto.py |
|
92% |
13 |
1 |
9 |
|
75% |
4 |
1 |
|
88% |
| faststream / _internal / utils / functions.py |
|
90% |
31 |
3 |
21 |
|
67% |
6 |
0 |
|
86% |
| faststream / _internal / utils / nuid.py |
|
89% |
35 |
4 |
4 |
|
75% |
4 |
1 |
|
87% |
| faststream / _internal / utils / path.py |
|
84% |
32 |
5 |
5 |
|
80% |
10 |
2 |
|
83% |
| faststream / asgi / app.py |
|
80% |
128 |
26 |
40 |
|
68% |
28 |
1 |
|
78% |
| faststream / asgi / factories / asyncapi / docs.py |
|
100% |
8 |
0 |
10 |
|
50% |
2 |
1 |
|
90% |
| faststream / asgi / factories / asyncapi / try_it_out.py |
|
91% |
69 |
6 |
20 |
|
75% |
8 |
2 |
|
90% |
| faststream / asgi / handlers.py |
|
95% |
38 |
2 |
64 |
|
100% |
4 |
0 |
|
95% |
| faststream / asgi / request.py |
|
83% |
54 |
9 |
9 |
|
59% |
22 |
9 |
|
76% |
| faststream / asgi / response.py |
|
100% |
24 |
0 |
16 |
|
83% |
6 |
1 |
|
97% |
| faststream / cli.py |
|
0% |
1 |
1 |
1 |
|
100% |
0 |
0 |
|
0% |
| faststream / confluent / helpers / admin.py |
|
97% |
29 |
1 |
6 |
|
67% |
6 |
2 |
|
91% |
| faststream / confluent / helpers / client.py |
|
87% |
106 |
14 |
135 |
|
68% |
40 |
13 |
|
82% |
| faststream / confluent / helpers / config.py |
|
98% |
107 |
2 |
12 |
|
70% |
10 |
3 |
|
96% |
| faststream / confluent / opentelemetry / provider.py |
|
88% |
25 |
3 |
37 |
|
62% |
8 |
3 |
|
82% |
| faststream / confluent / parser.py |
|
95% |
19 |
1 |
49 |
|
50% |
2 |
1 |
|
90% |
| faststream / confluent / publisher / producer.py |
|
87% |
55 |
7 |
40 |
|
75% |
4 |
1 |
|
86% |
| faststream / confluent / publisher / state.py |
|
80% |
25 |
5 |
13 |
|
100% |
0 |
0 |
|
80% |
| faststream / confluent / publisher / usecase.py |
|
96% |
56 |
2 |
59 |
|
100% |
0 |
0 |
|
96% |
| faststream / confluent / response.py |
|
100% |
39 |
0 |
8 |
|
88% |
8 |
1 |
|
98% |
| faststream / confluent / schemas / partition.py |
|
88% |
17 |
2 |
11 |
|
50% |
4 |
2 |
|
81% |
| faststream / confluent / security.py |
|
96% |
28 |
1 |
7 |
|
94% |
16 |
1 |
|
95% |
| faststream / confluent / subscriber / specification.py |
|
84% |
19 |
3 |
6 |
|
50% |
4 |
0 |
|
78% |
| faststream / confluent / subscriber / usecase.py |
|
99% |
95 |
1 |
74 |
|
92% |
12 |
1 |
|
98% |
| faststream / confluent / testing.py |
|
87% |
111 |
14 |
32 |
|
82% |
28 |
3 |
|
86% |
| faststream / exceptions.py |
|
91% |
58 |
5 |
6 |
|
100% |
0 |
0 |
|
91% |
| faststream / kafka / configs / broker.py |
|
92% |
24 |
2 |
13 |
|
75% |
4 |
1 |
|
89% |
| faststream / kafka / exceptions.py |
|
80% |
5 |
1 |
1 |
|
100% |
0 |
0 |
|
80% |
| faststream / kafka / helpers / rebalance_listener.py |
|
91% |
32 |
3 |
14 |
|
67% |
6 |
2 |
|
87% |
| faststream / kafka / message.py |
|
100% |
24 |
0 |
24 |
|
75% |
4 |
1 |
|
96% |
| faststream / kafka / opentelemetry / provider.py |
|
88% |
25 |
3 |
38 |
|
62% |
8 |
3 |
|
82% |
| faststream / kafka / publisher / producer.py |
|
85% |
66 |
10 |
41 |
|
90% |
10 |
1 |
|
86% |
| faststream / kafka / publisher / state.py |
|
77% |
26 |
6 |
14 |
|
100% |
0 |
0 |
|
77% |
| faststream / kafka / publisher / usecase.py |
|
96% |
55 |
2 |
103 |
|
100% |
0 |
0 |
|
96% |
| faststream / kafka / response.py |
|
100% |
39 |
0 |
8 |
|
88% |
8 |
1 |
|
98% |
| faststream / kafka / security.py |
|
96% |
25 |
1 |
6 |
|
93% |
14 |
1 |
|
95% |
| faststream / kafka / subscriber / specification.py |
|
86% |
21 |
3 |
6 |
|
67% |
6 |
0 |
|
81% |
| faststream / kafka / subscriber / usecase.py |
|
95% |
153 |
8 |
100 |
|
78% |
36 |
6 |
|
92% |
| faststream / kafka / testing.py |
|
89% |
88 |
10 |
42 |
|
86% |
28 |
2 |
|
88% |
| faststream / message / message.py |
|
98% |
40 |
1 |
26 |
|
88% |
8 |
1 |
|
96% |
| faststream / middlewares / acknowledgement / middleware.py |
|
94% |
51 |
3 |
21 |
|
85% |
26 |
4 |
|
91% |
| faststream / middlewares / exception.py |
|
98% |
45 |
1 |
37 |
|
92% |
12 |
1 |
|
96% |
| faststream / middlewares / logging.py |
|
100% |
18 |
0 |
19 |
|
50% |
2 |
1 |
|
95% |
| faststream / mqtt / broker / broker.py |
|
94% |
50 |
3 |
33 |
|
92% |
12 |
1 |
|
94% |
| faststream / mqtt / broker / config.py |
|
87% |
31 |
4 |
11 |
|
83% |
6 |
1 |
|
86% |
| faststream / mqtt / broker / logging.py |
|
100% |
15 |
0 |
12 |
|
50% |
2 |
1 |
|
94% |
| faststream / mqtt / broker / registrator.py |
|
89% |
19 |
2 |
18 |
|
75% |
4 |
1 |
|
87% |
| faststream / mqtt / message.py |
|
88% |
8 |
1 |
3 |
|
50% |
2 |
1 |
|
80% |
| faststream / mqtt / parser.py |
|
97% |
29 |
1 |
11 |
|
50% |
4 |
2 |
|
91% |
| faststream / mqtt / publisher / producer.py |
|
83% |
71 |
12 |
21 |
|
67% |
6 |
2 |
|
82% |
| faststream / mqtt / response.py |
|
75% |
20 |
5 |
23 |
|
50% |
2 |
1 |
|
73% |
| faststream / mqtt / security.py |
|
62% |
13 |
5 |
4 |
|
38% |
8 |
1 |
|
52% |
| faststream / mqtt / subscriber / factory.py |
|
89% |
9 |
1 |
10 |
|
50% |
2 |
1 |
|
82% |
| faststream / mqtt / subscriber / specification.py |
|
94% |
17 |
1 |
10 |
|
75% |
4 |
1 |
|
90% |
| faststream / mqtt / subscriber / usecase.py |
|
93% |
86 |
6 |
26 |
|
70% |
20 |
4 |
|
89% |
| faststream / mqtt / testing.py |
|
96% |
89 |
4 |
27 |
|
91% |
22 |
2 |
|
95% |
| faststream / nats / broker / broker.py |
|
88% |
93 |
11 |
170 |
|
64% |
22 |
4 |
|
83% |
| faststream / nats / broker / logging.py |
|
100% |
17 |
0 |
12 |
|
50% |
2 |
1 |
|
95% |
| faststream / nats / broker / state.py |
|
85% |
27 |
4 |
6 |
|
50% |
4 |
2 |
|
81% |
| faststream / nats / helpers / bucket_declarer.py |
|
94% |
16 |
1 |
8 |
|
75% |
4 |
1 |
|
90% |
| faststream / nats / helpers / obj_storage_declarer.py |
|
94% |
16 |
1 |
8 |
|
75% |
4 |
1 |
|
90% |
| faststream / nats / helpers / state.py |
|
87% |
15 |
2 |
4 |
|
100% |
0 |
0 |
|
87% |
| faststream / nats / helpers / stream_builder.py |
|
81% |
21 |
4 |
2 |
|
62% |
8 |
1 |
|
76% |
| faststream / nats / message.py |
|
71% |
38 |
11 |
6 |
|
44% |
18 |
2 |
|
62% |
| faststream / nats / parser.py |
|
98% |
44 |
1 |
12 |
|
75% |
8 |
2 |
|
94% |
| faststream / nats / publisher / producer.py |
|
94% |
70 |
4 |
39 |
|
100% |
0 |
0 |
|
94% |
| faststream / nats / publisher / usecase.py |
|
86% |
44 |
6 |
41 |
|
62% |
8 |
3 |
|
83% |
| faststream / nats / response.py |
|
97% |
29 |
1 |
20 |
|
75% |
8 |
2 |
|
92% |
| faststream / nats / schemas / obj_watch.py |
|
93% |
15 |
1 |
13 |
|
75% |
4 |
1 |
|
89% |
| faststream / nats / schemas / pull_sub.py |
|
92% |
13 |
1 |
13 |
|
75% |
4 |
1 |
|
88% |
| faststream / nats / security.py |
|
45% |
11 |
6 |
4 |
|
17% |
6 |
1 |
|
35% |
| faststream / nats / subscriber / factory.py |
|
70% |
112 |
34 |
18 |
|
64% |
92 |
31 |
|
67% |
| faststream / nats / subscriber / state.py |
|
0% |
39 |
39 |
12 |
|
100% |
0 |
0 |
|
0% |
| faststream / nats / subscriber / usecases / core_subscriber.py |
|
91% |
47 |
4 |
17 |
|
50% |
10 |
5 |
|
84% |
| faststream / nats / subscriber / usecases / key_value_subscriber.py |
|
92% |
62 |
5 |
21 |
|
69% |
16 |
5 |
|
87% |
| faststream / nats / subscriber / usecases / object_storage_subscriber.py |
|
93% |
67 |
5 |
22 |
|
69% |
16 |
5 |
|
88% |
| faststream / nats / subscriber / usecases / stream_basic.py |
|
100% |
41 |
0 |
17 |
|
75% |
8 |
2 |
|
96% |
| faststream / nats / subscriber / usecases / stream_pull_subscriber.py |
|
88% |
76 |
9 |
22 |
|
60% |
20 |
6 |
|
82% |
| faststream / nats / subscriber / usecases / stream_push_subscriber.py |
|
67% |
15 |
5 |
8 |
|
25% |
4 |
1 |
|
58% |
| faststream / nats / testing.py |
|
99% |
92 |
1 |
33 |
|
97% |
38 |
1 |
|
98% |
| faststream / opentelemetry / baggage.py |
|
100% |
41 |
0 |
12 |
|
88% |
8 |
1 |
|
98% |
| faststream / opentelemetry / middleware.py |
|
97% |
149 |
4 |
28 |
|
95% |
40 |
2 |
|
97% |
| faststream / prometheus / middleware.py |
|
100% |
64 |
0 |
22 |
|
92% |
12 |
1 |
|
99% |
| faststream / rabbit / broker / broker.py |
|
94% |
63 |
4 |
49 |
|
72% |
18 |
5 |
|
89% |
| faststream / rabbit / broker / logging.py |
|
100% |
14 |
0 |
9 |
|
50% |
2 |
1 |
|
94% |
| faststream / rabbit / helpers / declarer.py |
|
100% |
33 |
0 |
17 |
|
90% |
10 |
1 |
|
98% |
| faststream / rabbit / helpers / state.py |
|
80% |
10 |
2 |
8 |
|
100% |
0 |
0 |
|
80% |
| faststream / rabbit / message.py |
|
95% |
19 |
1 |
2 |
|
83% |
6 |
1 |
|
92% |
| faststream / rabbit / publisher / fake.py |
|
100% |
14 |
0 |
8 |
|
50% |
2 |
1 |
|
94% |
| faststream / rabbit / publisher / producer.py |
|
92% |
65 |
5 |
37 |
|
100% |
0 |
0 |
|
92% |
| faststream / rabbit / publisher / usecase.py |
|
95% |
61 |
3 |
20 |
|
67% |
12 |
4 |
|
90% |
| faststream / rabbit / response.py |
|
97% |
34 |
1 |
10 |
|
75% |
4 |
1 |
|
95% |
| faststream / rabbit / schemas / queue.py |
|
93% |
45 |
3 |
66 |
|
80% |
10 |
2 |
|
91% |
| faststream / rabbit / security.py |
|
91% |
11 |
1 |
4 |
|
83% |
6 |
1 |
|
88% |
| faststream / rabbit / subscriber / usecase.py |
|
100% |
71 |
0 |
26 |
|
93% |
14 |
1 |
|
99% |
| faststream / rabbit / testing.py |
|
97% |
118 |
3 |
30 |
|
94% |
52 |
3 |
|
96% |
| faststream / rabbit / types.py |
|
0% |
1 |
1 |
3 |
|
100% |
0 |
0 |
|
0% |
| faststream / redis / broker / broker.py |
|
96% |
55 |
2 |
89 |
|
70% |
10 |
3 |
|
92% |
| faststream / redis / configs / broker.py |
|
93% |
15 |
1 |
9 |
|
100% |
0 |
0 |
|
93% |
| faststream / redis / configs / state.py |
|
88% |
24 |
3 |
5 |
|
75% |
4 |
1 |
|
86% |
| faststream / redis / message.py |
|
98% |
58 |
1 |
10 |
|
75% |
4 |
1 |
|
97% |
| faststream / redis / parser / binary.py |
|
99% |
98 |
1 |
10 |
|
88% |
8 |
1 |
|
98% |
| faststream / redis / publisher / factory.py |
|
94% |
17 |
1 |
11 |
|
88% |
8 |
1 |
|
92% |
| faststream / redis / publisher / producer.py |
|
96% |
47 |
2 |
17 |
|
75% |
8 |
2 |
|
93% |
| faststream / redis / publisher / specification.py |
|
96% |
51 |
2 |
8 |
|
67% |
6 |
2 |
|
93% |
| faststream / redis / publisher / usecase.py |
|
92% |
106 |
9 |
21 |
|
100% |
0 |
0 |
|
92% |
| faststream / redis / schemas / list_sub.py |
|
93% |
14 |
1 |
3 |
|
100% |
0 |
0 |
|
93% |
| faststream / redis / schemas / proto.py |
|
40% |
10 |
6 |
4 |
|
50% |
6 |
3 |
|
44% |
| faststream / redis / schemas / stream_sub.py |
|
93% |
30 |
2 |
5 |
|
86% |
14 |
2 |
|
91% |
| faststream / redis / security.py |
|
95% |
19 |
1 |
5 |
|
88% |
8 |
1 |
|
93% |
| faststream / redis / subscriber / factory.py |
|
86% |
37 |
5 |
15 |
|
83% |
24 |
4 |
|
85% |
| faststream / redis / subscriber / specification.py |
|
96% |
51 |
2 |
12 |
|
67% |
6 |
2 |
|
93% |
| faststream / redis / subscriber / usecases / basic.py |
|
82% |
50 |
9 |
22 |
|
70% |
10 |
1 |
|
80% |
| faststream / redis / subscriber / usecases / channel_subscriber.py |
|
97% |
75 |
2 |
17 |
|
88% |
16 |
2 |
|
96% |
| faststream / redis / subscriber / usecases / list_subscriber.py |
|
98% |
91 |
2 |
18 |
|
81% |
16 |
3 |
|
95% |
| faststream / redis / subscriber / usecases / stream_subscriber.py |
|
91% |
128 |
12 |
86 |
|
69% |
32 |
6 |
|
86% |
| faststream / redis / testing.py |
|
99% |
135 |
1 |
35 |
|
96% |
52 |
2 |
|
98% |
| faststream / response / response.py |
|
96% |
48 |
2 |
64 |
|
83% |
6 |
1 |
|
94% |
| faststream / specification / asyncapi / factory.py |
|
97% |
29 |
1 |
12 |
|
100% |
4 |
0 |
|
97% |
| faststream / specification / asyncapi / message.py |
|
96% |
50 |
2 |
24 |
|
96% |
26 |
1 |
|
96% |
| faststream / specification / asyncapi / site.py |
|
47% |
30 |
16 |
11 |
|
50% |
2 |
1 |
|
47% |
| faststream / specification / asyncapi / v2_6_0 / generate.py |
|
96% |
85 |
3 |
16 |
|
92% |
48 |
4 |
|
95% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / channel.py |
|
89% |
36 |
4 |
17 |
|
50% |
8 |
4 |
|
82% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / amqp / operation.py |
|
89% |
18 |
2 |
3 |
|
50% |
4 |
2 |
|
82% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / channel.py |
|
87% |
15 |
2 |
3 |
|
50% |
4 |
2 |
|
79% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / kafka / operation.py |
|
60% |
15 |
6 |
4 |
|
0% |
4 |
0 |
|
47% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / channel.py |
|
78% |
45 |
10 |
18 |
|
70% |
30 |
5 |
|
75% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / main / operation.py |
|
61% |
46 |
18 |
18 |
|
43% |
30 |
5 |
|
54% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / channel.py |
|
87% |
15 |
2 |
3 |
|
50% |
4 |
2 |
|
79% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / mqtt / operation.py |
|
87% |
15 |
2 |
3 |
|
50% |
4 |
2 |
|
79% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / channel.py |
|
86% |
14 |
2 |
3 |
|
50% |
4 |
2 |
|
78% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / nats / operation.py |
|
54% |
13 |
6 |
4 |
|
0% |
4 |
0 |
|
41% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / channel.py |
|
88% |
16 |
2 |
3 |
|
50% |
4 |
2 |
|
80% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / redis / operation.py |
|
54% |
13 |
6 |
4 |
|
0% |
4 |
0 |
|
41% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / channel.py |
|
78% |
9 |
2 |
4 |
|
100% |
0 |
0 |
|
78% |
| faststream / specification / asyncapi / v2_6_0 / schema / bindings / sqs / operation.py |
|
78% |
9 |
2 |
4 |
|
100% |
0 |
0 |
|
78% |
| faststream / specification / asyncapi / v2_6_0 / schema / channels.py |
|
88% |
16 |
2 |
6 |
|
50% |
2 |
1 |
|
83% |
| faststream / specification / asyncapi / v2_6_0 / schema / components.py |
|
75% |
8 |
2 |
4 |
|
50% |
2 |
1 |
|
70% |
| faststream / specification / asyncapi / v2_6_0 / schema / contact.py |
|
89% |
19 |
2 |
19 |
|
88% |
8 |
1 |
|
89% |
| faststream / specification / asyncapi / v2_6_0 / schema / docs.py |
|
89% |
18 |
2 |
19 |
|
88% |
8 |
1 |
|
88% |
| faststream / specification / asyncapi / v2_6_0 / schema / license.py |
|
89% |
18 |
2 |
19 |
|
88% |
8 |
1 |
|
88% |
| faststream / specification / asyncapi / v2_6_0 / schema / message.py |
|
83% |
24 |
4 |
6 |
|
50% |
4 |
2 |
|
79% |
| faststream / specification / asyncapi / v2_6_0 / schema / operations.py |
|
89% |
18 |
2 |
9 |
|
50% |
2 |
1 |
|
85% |
| faststream / specification / asyncapi / v2_6_0 / schema / servers.py |
|
82% |
22 |
4 |
5 |
|
50% |
4 |
2 |
|
77% |
| faststream / specification / asyncapi / v2_6_0 / schema / tag.py |
|
88% |
17 |
2 |
17 |
|
83% |
6 |
1 |
|
87% |
| faststream / specification / asyncapi / v3_0_0 / generate.py |
|
97% |
103 |
3 |
19 |
|
93% |
42 |
3 |
|
96% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / channel.py |
|
83% |
12 |
2 |
4 |
|
50% |
4 |
2 |
|
75% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / amqp / operation.py |
|
89% |
18 |
2 |
3 |
|
50% |
4 |
2 |
|
82% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / channel.py |
|
78% |
45 |
10 |
5 |
|
70% |
30 |
5 |
|
75% |
| faststream / specification / asyncapi / v3_0_0 / schema / bindings / main / operation.py |
|
61% |
46 |
18 |
5 |
|
43% |
30 |
5 |
|
54% |
| faststream / specification / asyncapi / v3_0_0 / schema / channels.py |
|
90% |
20 |
2 |
7 |
|
50% |
2 |
1 |
|
86% |
| faststream / specification / asyncapi / v3_0_0 / schema / components.py |
|
75% |
8 |
2 |
4 |
|
50% |
2 |
1 |
|
70% |
| faststream / specification / asyncapi / v3_0_0 / schema / operations.py |
|
91% |
22 |
2 |
10 |
|
50% |
2 |
1 |
|
88% |
| faststream / specification / asyncapi / v3_0_0 / schema / servers.py |
|
87% |
15 |
2 |
5 |
|
50% |
2 |
1 |
|
82% |
| faststream / specification / base / info.py |
|
75% |
8 |
2 |
2 |
|
50% |
2 |
1 |
|
70% |
| tests / asgi / testcase.py |
|
99% |
238 |
1 |
100 |
|
100% |
2 |
0 |
|
99% |
| tests / asyncapi / base / basic.py |
|
0% |
2 |
2 |
4 |
|
100% |
0 |
0 |
|
0% |
| tests / asyncapi / base / v2_6_0 / arguments.py |
|
99% |
280 |
4 |
86 |
|
94% |
36 |
2 |
|
98% |
| tests / asyncapi / base / v3_0_0 / arguments.py |
|
99% |
270 |
4 |
87 |
|
97% |
32 |
1 |
|
98% |
| tests / asyncapi / confluent / v2_6_0 / base.py |
|
67% |
3 |
1 |
3 |
|
100% |
0 |
0 |
|
67% |
| tests / asyncapi / confluent / v3_0_0 / base.py |
|
67% |
3 |
1 |
3 |
|
100% |
0 |
0 |
|
67% |
| tests / brokers / base / basic.py |
|
75% |
4 |
1 |
23 |
|
100% |
0 |
0 |
|
75% |
| tests / brokers / base / codec.py |
|
98% |
46 |
1 |
9 |
|
100% |
0 |
0 |
|
98% |
| tests / brokers / base / connection.py |
|
95% |
20 |
1 |
3 |
|
100% |
0 |
0 |
|
95% |
| tests / brokers / base / consume.py |
|
100% |
199 |
0 |
10 |
|
90% |
10 |
1 |
|
99% |
| tests / brokers / base / fastapi.py |
|
99% |
415 |
5 |
54 |
|
100% |
6 |
0 |
|
99% |
| tests / brokers / base / middlewares.py |
|
99% |
468 |
7 |
16 |
|
100% |
2 |
0 |
|
99% |
| tests / brokers / base / parser.py |
|
100% |
158 |
0 |
6 |
|
75% |
4 |
1 |
|
99% |
| tests / brokers / base / publish.py |
|
99% |
228 |
1 |
18 |
|
100% |
2 |
0 |
|
99% |
| tests / brokers / confluent / conftest.py |
|
89% |
9 |
1 |
3 |
|
100% |
0 |
0 |
|
89% |
| tests / brokers / confluent / test_security.py |
|
33% |
6 |
4 |
21 |
|
100% |
0 |
0 |
|
33% |
| tests / brokers / confluent / test_test_client.py |
|
99% |
146 |
2 |
37 |
|
100% |
0 |
0 |
|
99% |
| tests / brokers / kafka / conftest.py |
|
89% |
9 |
1 |
3 |
|
100% |
0 |
0 |
|
89% |
| tests / brokers / kafka / test_test_client.py |
|
99% |
167 |
2 |
41 |
|
100% |
0 |
0 |
|
99% |
| tests / brokers / mqtt / conftest.py |
|
92% |
13 |
1 |
3 |
|
100% |
0 |
0 |
|
92% |
| tests / brokers / mqtt / test_consume.py |
|
100% |
30 |
0 |
5 |
|
88% |
8 |
1 |
|
97% |
| tests / brokers / mqtt / test_testclient.py |
|
99% |
81 |
1 |
8 |
|
100% |
6 |
0 |
|
99% |
| tests / brokers / nats / test_consume.py |
|
100% |
424 |
0 |
12 |
|
83% |
36 |
6 |
|
99% |
| tests / brokers / nats / test_test_client.py |
|
97% |
127 |
4 |
30 |
|
100% |
0 |
0 |
|
97% |
| tests / brokers / rabbit / conftest.py |
|
94% |
16 |
1 |
4 |
|
100% |
0 |
0 |
|
94% |
| tests / brokers / rabbit / test_test_client.py |
|
97% |
119 |
3 |
22 |
|
100% |
0 |
0 |
|
97% |
| tests / brokers / redis / conftest.py |
|
91% |
11 |
1 |
3 |
|
100% |
0 |
0 |
|
91% |
| tests / brokers / redis / test_autoclaim.py |
|
100% |
135 |
0 |
23 |
|
75% |
8 |
2 |
|
99% |
| tests / brokers / redis / test_consume.py |
|
99% |
448 |
1 |
21 |
|
86% |
28 |
4 |
|
99% |
| tests / brokers / redis / test_test_client.py |
|
96% |
137 |
6 |
18 |
|
100% |
0 |
0 |
|
96% |
| tests / brokers / supervisor / test_supervisor.py |
|
95% |
43 |
2 |
6 |
|
100% |
0 |
0 |
|
95% |
| tests / cli / conftest.py |
|
94% |
89 |
5 |
35 |
|
88% |
26 |
3 |
|
93% |
| tests / cli / supervisors / test_watchfiles.py |
|
90% |
30 |
3 |
12 |
|
100% |
0 |
0 |
|
90% |
| tests / cli / test_asyncapi_docs.py |
|
96% |
53 |
2 |
11 |
|
100% |
0 |
0 |
|
96% |
| tests / conftest.py |
|
97% |
37 |
1 |
14 |
|
100% |
2 |
0 |
|
97% |
| tests / docs / confluent / publish_with_partition_key / test_app.py |
|
73% |
15 |
4 |
3 |
|
100% |
0 |
0 |
|
73% |
| tests / docs / getting_started / config / test_settings_base_1.py |
|
67% |
3 |
1 |
2 |
|
100% |
0 |
0 |
|
67% |
| tests / docs / kafka / publish_with_partition_key / test_app.py |
|
73% |
15 |
4 |
3 |
|
100% |
0 |
0 |
|
73% |
| tests / examples / nats / test_e07_object_storage.py |
|
84% |
19 |
3 |
5 |
|
67% |
6 |
2 |
|
80% |
| tests / marks.py |
|
66% |
29 |
10 |
7 |
|
100% |
0 |
0 |
|
66% |
| tests / opentelemetry / basic.py |
|
99% |
288 |
1 |
23 |
|
100% |
16 |
0 |
|
99% |
| tests / prometheus / basic.py |
|
100% |
87 |
0 |
20 |
|
93% |
14 |
1 |
|
99% |
| tests / utils / context / test_main.py |
|
99% |
124 |
1 |
7 |
|
100% |
0 |
0 |
|
99% |