fix interval tick (#108)

* fix interval tick * fmt
AcalaNetwork · Oct 3, 2023 · c5fe1c8 · c5fe1c8
1 parent ba32a53
commit c5fe1c8
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 4 deletions.
diff --git a/src/extensions/api/eth.rs b/src/extensions/api/eth.rs
@@ -77,12 +77,12 @@ impl EthApi {
         let client2 = client.clone();
         tokio::spawn(async move {
             let mut interval = tokio::time::interval(stale_timeout);
+            interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Delay);
+
             let client = client2.clone();
 
             loop {
                 let run = async {
-                    interval.reset();
-
                     // query current head
                     let head = client
                         .request("eth_getBlockByNumber", vec!["latest".into(), true.into()])
@@ -97,6 +97,9 @@ impl EthApi {
                         .subscribe("eth_subscribe", ["newHeads".into()].into(), "eth_unsubscribe")
                         .await?;
 
+                    // Reset the interval
+                    interval.reset();
+
                     loop {
                         tokio::select! {
                             val = sub.next() => {

diff --git a/src/extensions/api/substrate.rs b/src/extensions/api/substrate.rs
@@ -70,17 +70,19 @@ impl SubstrateApi {
 
         tokio::spawn(async move {
             let mut interval = tokio::time::interval(stale_timeout);
+            interval.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Delay);
 
             let client = client.clone();
 
             loop {
                 let run = async {
-                    interval.reset();
-
                     let mut sub = client
                         .subscribe("chain_subscribeNewHeads", [].into(), "chain_unsubscribeNewHeads")
                         .await?;
 
+                    // Reset the interval
+                    interval.reset();
+
                     loop {
                         tokio::select! {
                             val = sub.next() => {