Browse Source

修复先登录后订阅 逻辑错误

JiahengHe 1 year ago
parent
commit
66aa2c9107
1 changed files with 6 additions and 4 deletions
  1. 6 4
      exchanges/src/socket_tool.rs

+ 6 - 4
exchanges/src/socket_tool.rs

@@ -114,11 +114,13 @@ impl AbstractWsMode {
                             //登录成功
                             info!("ws登录成功:{:?}", data);
                             info!("订阅内容:{:?}", subscribe_array.clone());
-                            for s in &subscribe_array {
-                                let mut write_lock = ws_write_arc.lock().await;
-                                write_lock.send(Message::Text(s.parse().unwrap())).await.expect("订阅消息失败");
+                            if is_first_login {
+                                for s in &subscribe_array {
+                                    let mut write_lock = ws_write_arc.lock().await;
+                                    write_lock.send(Message::Text(s.parse().unwrap())).await.expect("订阅消息失败");
+                                }
+                                info!("订阅完成!");
                             }
-                            info!("订阅完成!");
                         }
                         -201 => {
                             //订阅成功