htx 订阅bug修复

exchanges/src/htx_swap_ws.rs

@@ -191,14 +191,15 @@ impl HtxSwapWs {
     pub fn get_subscription(&self) -> Vec<Value> {
         let mut args = vec![];
         // 只获取第一个
-        let symbol = self.symbol_s.get(0).unwrap().replace("_", "-");
-
-        for subscribe_type in &self.subscribe_types {
-            let ty_str = Self::enum_to_string(symbol.clone(),
-                                              subscribe_type.clone(),
-                                              self.login_param.clone(),
-            );
-            args.push(ty_str);
+        // let symbol = self.symbol_s.get(0).unwrap().replace("_", "-");
+        for symbol in &self.symbol_s {
+            for subscribe_type in &self.subscribe_types {
+                let ty_str = Self::enum_to_string(symbol.clone(),
+                                                  subscribe_type.clone(),
+                                                  self.login_param.clone(),
+                );
+                args.push(ty_str);
+            }
         }
         args
     }