Fix wrong reconnect timing

2022-12-23 00:35:59 +01:00
parent 921f314f00
commit 0c9c186b33
3 changed files with 4 additions and 4 deletions
@@ -369,8 +369,6 @@ impl EngineInner {
                return Ok(());
            }

-            self.reconnect_interval.lock().tick().await;
-
            if self.full_reconnect.load(Ordering::SeqCst) {
                if i == 0 {
                    let _ = self.engine_emitter.send(EngineEvent::Restarting).await;
@@ -399,6 +397,8 @@ impl EngineInner {
                    return Ok(());
                }
            }
+
+            self.reconnect_interval.lock().tick().await;
        }

        Err(EngineError::Connection("failed to reconnect".to_owned()))