优化

exchanges/src/binance_swap_ws.rs

@@ -224,7 +224,6 @@ impl BinanceSwapWs {
                     } else {
                         let sender = self.sender.clone();
                         tokio::spawn(async move {
-                            info!(?res_data);
                             sender.send(res_data).await.unwrap();
                         });
                         tokio::spawn(async move {});
@@ -272,7 +271,10 @@ impl BinanceSwapWs {
                         writeln!(stdout, "订阅成功：{:?}", res_data.data).unwrap();
                     } else {
                         let sender = self.sender.clone();
-                        sender.send(res_data).await.unwrap();
+                        tokio::spawn(async move {
+                            sender.send(res_data).await.unwrap();
+                        });
+                        tokio::spawn(async move {});
                     }
                 }
                 Ok(Message::Ping(s)) => {

exchanges/src/kucoin_swap_ws.rs

@@ -310,7 +310,11 @@ impl KucoinSwapWs {
                             break;
                         }
 
-                        self.sender.send(res_data).await.unwrap();
+                        let sender = self.sender.clone();
+                        tokio::spawn(async move {
+                            sender.send(res_data).await.unwrap();
+                        });
+                        tokio::spawn(async move {});
                     }
                 }
                 Ok(Message::Ping(s)) => {
@@ -380,7 +384,11 @@ impl KucoinSwapWs {
                             break;
                         }
 
-                        self.sender.send(res_data).await.unwrap();
+                        let sender = self.sender.clone();
+                        tokio::spawn(async move {
+                            sender.send(res_data).await.unwrap();
+                        });
+                        tokio::spawn(async move {});
                     }
                 }
                 Ok(Message::Ping(s)) => {