skyfffire 1 жил өмнө
parent
commit
353a681a5e

+ 1 - 3
exchanges/src/socket_tool.rs

@@ -205,9 +205,7 @@ impl AbstractWsMode {
                             spawn(async move {
                                 let read = r.lock().await;
 
-                                if read.is_empty() {
-                                    read.unbounded_send(t.clone()).unwrap();
-                                }
+                                read.unbounded_send(t.clone()).unwrap();
                             });
                         }
                     });