Merge branch 'master' of http://git.skyfffire.com/skyfffire/as-rust

exchanges/src/binance_swap_ws.rs

@@ -2,6 +2,7 @@ use std::collections::{BTreeMap};
 use std::{io};
 use std::io::{Write};
 use std::net::{IpAddr, Ipv4Addr, SocketAddr};
+use std::time::Duration;
 use tokio::sync::mpsc::Sender;
 use tracing::{info, trace};
 use crate::{proxy};
@@ -141,20 +142,6 @@ impl BinanceSwapWs {
             }
         }
 
-//         let str = json!({
-//             // "method": "SUBSCRIBE",
-//             // "params":args,
-//             // "id": 1
-//
-// "method": "SUBSCRIBE",
-// "params":
-// [
-// "btcusdt@aggTrade",
-// "btcusdt@depth"
-// ],
-// "id": 1
-//         });
-
         trace!("订阅信息：{}", str.to_string());
         str.to_string()
     }
@@ -226,6 +213,7 @@ impl BinanceSwapWs {
         /*****消息溜***/
         let mut stdout = io::stdout();
         loop {
+            tokio::time::sleep(Duration::from_millis(1)).await;
             let msg = web_socket.read_message();
             match msg {
                 Ok(Message::Text(text)) => {
@@ -274,6 +262,7 @@ impl BinanceSwapWs {
         /*****消息溜***/
         let mut stdout = io::stdout();
         loop {
+            tokio::time::sleep(Duration::from_millis(1)).await;
             let msg = web_socket.read_message();
             match msg {
                 Ok(Message::Text(text)) => {

exchanges/src/gate_swap_ws.rs

@@ -1,5 +1,6 @@
 use std::collections::{BTreeMap};
 use std::net::{IpAddr, Ipv4Addr, SocketAddr};
+use std::time::Duration;
 use tokio::sync::mpsc::Sender;
 use serde_json::{json, Value};
 use hex;
@@ -294,6 +295,7 @@ impl GateSwapWs {
         /*****消息溜***/
         let mut start_ping = chrono::Utc::now().timestamp_millis();
         loop {
+            tokio::time::sleep(Duration::from_millis(1)).await;
             let msg = web_socket.read_message();
             match msg {
                 Ok(Message::Text(text)) => {
@@ -363,6 +365,7 @@ impl GateSwapWs {
         /*****消息溜***/
         let mut start_ping = chrono::Utc::now().timestamp_millis();
         loop {
+            tokio::time::sleep(Duration::from_millis(1)).await;
             let msg = web_socket.read_message();
             match msg {
                 Ok(Message::Text(text)) => {

exchanges/src/kucoin_swap_ws.rs

@@ -2,6 +2,7 @@ use std::collections::{BTreeMap, HashSet};
 use std::{io};
 use std::io::{Write};
 use std::net::{IpAddr, Ipv4Addr, SocketAddr};
+use std::time::Duration;
 use tokio::sync::mpsc::Sender;
 use serde_json::{json};
 use tracing::{info, trace};
@@ -278,6 +279,7 @@ impl KucoinSwapWs {
         let mut ping_interval = chrono::Utc::now().timestamp_millis();
         let mut ping_timeout = chrono::Utc::now().timestamp_millis();
         loop {
+            tokio::time::sleep(Duration::from_millis(1)).await;
             let msg = web_socket.read_message();
             match msg {
                 Ok(Message::Text(text)) => {
@@ -347,6 +349,7 @@ impl KucoinSwapWs {
         let mut ping_interval = chrono::Utc::now().timestamp_millis();
         let mut ping_timeout = chrono::Utc::now().timestamp_millis();
         loop {
+            tokio::time::sleep(Duration::from_millis(1)).await;
             let msg = web_socket.read_message();
             match msg {
                 Ok(Message::Text(text)) => {