|
|
@@ -80,7 +80,7 @@ impl AbstractWsMode {
|
|
|
let mut write_lock2 = write_clone2.lock().await;
|
|
|
write_lock2.send(message).await?;
|
|
|
}
|
|
|
- Ok::<(), tokio_tungstenite::tungstenite::Error>(())
|
|
|
+ Ok::<(), Error>(())
|
|
|
};
|
|
|
let write_clone3 = Arc::clone(&write_arc);
|
|
|
let ws_to_stdout = async {
|
|
|
@@ -96,6 +96,7 @@ impl AbstractWsMode {
|
|
|
let mut data = response_data.unwrap();
|
|
|
data.label = lable.clone();
|
|
|
data.time = chrono::Utc::now().timestamp_micros();
|
|
|
+
|
|
|
let code = data.code.clone();
|
|
|
/*
|
|
|
200 -正确返回
|
|
|
@@ -145,7 +146,7 @@ impl AbstractWsMode {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- Ok::<(), tokio_tungstenite::tungstenite::Error>(())
|
|
|
+ Ok::<(), Error>(())
|
|
|
};
|
|
|
|
|
|
//必须操作。,因为不同于其他的高级语言,有自动内存管理,所以为了防范地址改变,所以需要做此处理
|