jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: delay initial filter tick (#10564)

Browse Source
This commit is contained in:
Matthias Seitz
2024-08-27 11:52:16 +02:00
committed by GitHub
parent 1c427c6c6a
commit 763e961642
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/rpc/rpc/src/eth/filter.rs
View File

@ -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;