From b916cf1f4f26a4901e0e01721be04f24647dfc69 Mon Sep 17 00:00:00 2001 From: Daniel Freire Date: Fri, 26 Jul 2024 12:00:03 -0300 Subject: [PATCH] fix --- src/eth/rpc/rpc_subscriptions.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/eth/rpc/rpc_subscriptions.rs b/src/eth/rpc/rpc_subscriptions.rs index 333fb9bd9..c3be20ebf 100644 --- a/src/eth/rpc/rpc_subscriptions.rs +++ b/src/eth/rpc/rpc_subscriptions.rs @@ -402,7 +402,7 @@ impl RpcSubscriptionsConnected { filter_to_subscription_map.insert(filter.clone(), SubscriptionWithFilter::new(inner, filter)); #[cfg(feature = "metrics")] - let sub_count = self.logs.read().await.values().flat_map(HashMap::values).count(); + let sub_count = subs.values().flat_map(HashMap::values).count(); #[cfg(feature = "metrics")] metrics::set_rpc_subscriptions_active(sub_count as u64, label::LOGS); }