优化 开关

exchanges/src/binance_swap_ws.rs

@@ -210,6 +210,12 @@ impl BinanceSwapWs {
                 };
             }
             trace!("退出来咯");
+
+            let bool_v1_clone = Arc::clone(&bool_v1);
+            let bool_v1_v = bool_v1_clone.load(Ordering::SeqCst);
+            if !bool_v1_v {
+                break;
+            }
         }
     }
 

exchanges/src/gate_swap_ws.rs

@@ -281,7 +281,13 @@ impl GateSwapWs {
                     }
                 };
             }
-            trace!("退出来咯")
+            trace!("退出来咯");
+
+            let bool_v1_clone = Arc::clone(&bool_v1);
+            let bool_v1_v = bool_v1_clone.load(Ordering::SeqCst);
+            if !bool_v1_v {
+                break;
+            }
         }
     }
 

exchanges/src/kucoin_swap_ws.rs

@@ -302,7 +302,13 @@ impl KucoinSwapWs {
                     }
                 };
             }
-            trace!("退出来咯")
+            trace!("退出来咯");
+
+            let bool_v1_clone = Arc::clone(&bool_v1);
+            let bool_v1_v = bool_v1_clone.load(Ordering::SeqCst);
+            if !bool_v1_v {
+                break;
+            }
         }
     }
 

exchanges/src/okx_swap_rest.rs

@@ -7,7 +7,6 @@ use rust_decimal_macros::dec;
 use tracing::trace;
 use crate::http_tool::RestTool;
 use crate::response_base::ResponseData;
-use hex;
 use ring::hmac;
 
 #[derive(Clone, Debug)]