@@ -30,24 +30,24 @@ class FastStreamTelemetryMiddlewareProtocol(typing.Protocol):
3030 def __init__ (
3131 self ,
3232 * ,
33- tracer_provider : TracerProvider | None = None ,
34- meter_provider : MeterProvider | None = None ,
35- meter : Meter | None = None ,
33+ tracer_provider : typing . Optional [ " TracerProvider" ] = None ,
34+ meter_provider : typing . Optional [ " MeterProvider" ] = None ,
35+ meter : typing . Optional [ " Meter" ] = None ,
3636 ) -> None : ...
37- def __call__ (self , msg : typing .Any | None ) -> faststream .BaseMiddleware : ... # noqa: ANN401
37+ def __call__ (self , msg : typing .Any | None ) -> " faststream.BaseMiddleware" : ... # noqa: ANN401
3838
3939
4040@typing .runtime_checkable
4141class FastStreamPrometheusMiddlewareProtocol (typing .Protocol ):
4242 def __init__ (
4343 self ,
4444 * ,
45- registry : prometheus_client .CollectorRegistry ,
45+ registry : " prometheus_client.CollectorRegistry" ,
4646 app_name : str = ...,
4747 metrics_prefix : str = "faststream" ,
4848 received_messages_size_buckets : typing .Sequence [float ] | None = None ,
4949 ) -> None : ...
50- def __call__ (self , msg : typing .Any | None ) -> faststream .BaseMiddleware : ... # noqa: ANN401
50+ def __call__ (self , msg : typing .Any | None ) -> " faststream.BaseMiddleware" : ... # noqa: ANN401
5151
5252
5353@dataclasses .dataclass (kw_only = True , slots = True , frozen = True )
0 commit comments