From 763e961642a17299341d6a36de6ef5fc0e330e8a Mon Sep 17 00:00:00 2001 From: Matthias Seitz Date: Tue, 27 Aug 2024 11:52:16 +0200 Subject: [PATCH] chore: delay initial filter tick (#10564) --- crates/rpc/rpc/src/eth/filter.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/crates/rpc/rpc/src/eth/filter.rs b/crates/rpc/rpc/src/eth/filter.rs index 9645bb6ec7..f3f0ea72b6 100644 --- a/crates/rpc/rpc/src/eth/filter.rs +++ b/crates/rpc/rpc/src/eth/filter.rs @@ -98,7 +98,10 @@ where /// Endless future that [`Self::clear_stale_filters`] every `stale_filter_ttl` interval. /// Nonetheless, this endless future frees the thread at every await point. async fn watch_and_clear_stale_filters(&self) { - let mut interval = tokio::time::interval(self.inner.stale_filter_ttl); + let mut interval = tokio::time::interval_at( + tokio::time::Instant::now() + self.inner.stale_filter_ttl, + self.inner.stale_filter_ttl, + ); interval.set_missed_tick_behavior(MissedTickBehavior::Delay); loop { interval.tick().await;