|
|
@@ -100,12 +100,13 @@ impl AbstractWsMode {
|
|
|
let data = response_data.unwrap();
|
|
|
|
|
|
if data.code == "200" {
|
|
|
- let mut data_c = data.clone();
|
|
|
- data_c.time = chrono::Utc::now().timestamp_micros();
|
|
|
- data_c.label = lable.clone();
|
|
|
let r = read1.clone();
|
|
|
let read = r.lock().await;
|
|
|
|
|
|
+ let mut data_c = data.clone();
|
|
|
+ data_c.label = lable.clone();
|
|
|
+ data_c.time = chrono::Utc::now().timestamp_micros();
|
|
|
+
|
|
|
if data_c.label.contains("gate_usdt_swap") {
|
|
|
if data_c.channel == "futures.order_book" {
|
|
|
if read.len() == 0 {
|