@@ -30,24 +30,24 @@ class FastStreamTelemetryMiddlewareProtocol(typing.Protocol):
30
30
def __init__ (
31
31
self ,
32
32
* ,
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 ,
36
36
) -> 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
38
38
39
39
40
40
@typing .runtime_checkable
41
41
class FastStreamPrometheusMiddlewareProtocol (typing .Protocol ):
42
42
def __init__ (
43
43
self ,
44
44
* ,
45
- registry : prometheus_client .CollectorRegistry ,
45
+ registry : " prometheus_client.CollectorRegistry" ,
46
46
app_name : str = ...,
47
47
metrics_prefix : str = "faststream" ,
48
48
received_messages_size_buckets : typing .Sequence [float ] | None = None ,
49
49
) -> 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
51
51
52
52
53
53
@dataclasses .dataclass (kw_only = True , slots = True , frozen = True )
0 commit comments