diff --git a/crates/rpc/rpc/src/eth/filter.rs b/crates/rpc/rpc/src/eth/filter.rs index a835d28f25..9c7bdda56d 100644 --- a/crates/rpc/rpc/src/eth/filter.rs +++ b/crates/rpc/rpc/src/eth/filter.rs @@ -1,12 +1,10 @@ use crate::{ eth::error::EthApiError, result::{internal_rpc_err, rpc_error_with_code, ToRpcResult}, + EthSubscriptionIdProvider, }; use async_trait::async_trait; -use jsonrpsee::{ - core::RpcResult, - server::{IdProvider, RandomIntegerIdProvider}, -}; +use jsonrpsee::{core::RpcResult, server::IdProvider}; use reth_primitives::{ filter::{Filter, FilterBlockOption, FilteredParams}, Block, U256, @@ -36,7 +34,7 @@ impl EthFilter { client, active_filters: Default::default(), pool, - id_provider: Arc::new(RandomIntegerIdProvider), + id_provider: Arc::new(EthSubscriptionIdProvider::default()), max_logs_in_response: DEFAULT_MAX_LOGS_IN_RESPONSE, }; Self { inner: Arc::new(inner) }