File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed
services/webserver/src/server/websocket Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change @@ -71,15 +71,11 @@ impl MessageHandler {
71
71
#[ derive( Clone ) ]
72
72
struct MetricsHandler {
73
73
telemetry : Arc < Telemetry < Metrics > > ,
74
- api_key : ApiKey ,
75
74
}
76
75
77
76
impl MetricsHandler {
78
- fn new ( telemetry : Arc < Telemetry < Metrics > > , api_key : & ApiKey ) -> Self {
79
- Self {
80
- telemetry,
81
- api_key : api_key. to_owned ( ) ,
82
- }
77
+ fn new ( telemetry : Arc < Telemetry < Metrics > > ) -> Self {
78
+ Self { telemetry }
83
79
}
84
80
85
81
fn track_subscription (
@@ -88,7 +84,6 @@ impl MetricsHandler {
88
84
change : SubscriptionChange ,
89
85
) {
90
86
if let Some ( metrics) = self . telemetry . base_metrics ( ) {
91
- let subject = subscription. payload . subject . clone ( ) ;
92
87
metrics. update_user_subscription_count ( & change) ;
93
88
match change {
94
89
SubscriptionChange :: Added => {
@@ -209,7 +204,7 @@ impl WsSession {
209
204
rate_limiter : Arc < RateLimitsController > ,
210
205
socket : WebSocket ,
211
206
) -> Self {
212
- let metrics = MetricsHandler :: new ( telemetry, api_key ) ;
207
+ let metrics = MetricsHandler :: new ( telemetry) ;
213
208
let connection =
214
209
SubscriptionManager :: new ( api_key, metrics, rate_limiter) ;
215
210
let messaging = MessageHandler :: new ( api_key) ;
You can’t perform that action at this time.
0 commit comments