MCPcopy
hub / github.com/ag2ai/faststream / rabbit.py

File rabbit.py

tests/mypy/rabbit.py:None–None  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1from collections.abc import Awaitable, Callable
2
3import prometheus_client
4from aio_pika import IncomingMessage

Callers

nothing calls this directly

Calls 9

RabbitBrokerClass · 0.90
RabbitRouterClass · 0.90
RabbitRouteClass · 0.90
RabbitTelemetryMiddlewareClass · 0.90
RabbitPrometheusMiddlewareClass · 0.90
include_routersMethod · 0.80
subscriberMethod · 0.45
add_middlewareMethod · 0.45
include_routerMethod · 0.45

Tested by

no test coverage detected