From 9c5cdba1ad5711bfaa081fd9b65d9c3818dcc9a1 Mon Sep 17 00:00:00 2001
From: Bryan Chen <xlchen1291@gmail.com>
Date: Tue, 3 Oct 2023 17:24:09 +1300
Subject: [PATCH] fix

---
 src/extensions/client/mod.rs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/extensions/client/mod.rs b/src/extensions/client/mod.rs
index 2409e10..10e590c 100644
--- a/src/extensions/client/mod.rs
+++ b/src/extensions/client/mod.rs
@@ -108,7 +108,7 @@ impl Client {
             let tx = tx2;
 
             let connect_backoff_counter = Arc::new(AtomicU32::new(0));
-            let subscribe_backoff_counter = Arc::new(AtomicU32::new(0));
+            let request_backoff_counter = Arc::new(AtomicU32::new(0));
 
             let current_endpoint = AtomicUsize::new(0);
 
@@ -165,7 +165,7 @@ impl Client {
             let handle_message = |message: Message, ws: Arc<WsClient>| {
                 let tx = tx.clone();
                 let connect_backoff_counter = connect_backoff_counter.clone();
-                let subscribe_backoff_counter = subscribe_backoff_counter.clone();
+                let request_backoff_counter = request_backoff_counter.clone();
 
                 tokio::spawn(async move {
                     match message {
@@ -209,7 +209,7 @@ impl Client {
                                         | Error::RestartNeeded(_)
                                         | Error::MaxSlotsExceeded => {
                                             tokio::time::sleep(get_backoff_time(
-                                                &connect_backoff_counter,
+                                                &request_backoff_counter,
                                             ))
                                             .await;
 
@@ -247,7 +247,7 @@ impl Client {
                                 ws.subscribe(&subscribe, params.clone(), &unsubscribe).await;
                             match result {
                                 result @ Ok(_) => {
-                                    subscribe_backoff_counter
+                                    request_backoff_counter
                                         .store(0, std::sync::atomic::Ordering::Relaxed);
 
                                     if let Err(e) = response.send(result) {
@@ -283,7 +283,7 @@ impl Client {
                                         | Error::RestartNeeded(_)
                                         | Error::MaxSlotsExceeded => {
                                             tokio::time::sleep(get_backoff_time(
-                                                &subscribe_backoff_counter,
+                                                &request_backoff_counter,
                                             ))
                                             .await;