binan 接口提交

src/exchange_libs.rs

@@ -655,7 +655,7 @@ impl SocketTool {
                 match msg {
                     Ok(Message::Text(text)) => {
                         writeln!(stdout, "{:?}", text).unwrap();
-                        println!("??????????---{0}--",exc_name);
+                        println!("??????????---{0}--", exc_name);
                         if exc_name == "binance" {
                             SocketTool::hook_fn_binance(text, parse_fn)
                         } else if exc_name == "okx" {
@@ -732,13 +732,13 @@ impl SocketTool {
     }
 
     //币安--深度信息
-    pub fn binance_run_kline(b_array: Vec<&str>, channel: String, time_str: String, parse_fn: ParseFn) {
-        let str = format!("{}_{}", channel, time_str);
+    pub fn binance_run_kline(b_array: Vec<&str>, time_str: String, parse_fn: ParseFn) {
+        let str = format!("kline_{}", time_str);
         SocketTool::binance_run(b_array, str, parse_fn);
     }
     //币安--深度信息
-    pub fn binance_run_depth(b_array: Vec<&str>, channel: String, time_str: String, parse_fn: ParseFn) {
-        let str = format!("{}@{}", channel, time_str);
+    pub fn binance_run_depth(b_array: Vec<&str>, time_str: String, parse_fn: ParseFn) {
+        let str = format!("depth@{}", time_str);
         SocketTool::binance_run(b_array, str, parse_fn);
     }
     //币安--订阅