Quellcode durchsuchen

解决coinex http请求链接被重置退出程序问题

JiahengHe vor 1 Jahr
Ursprung
Commit
634086a6ac
1 geänderte Dateien mit 15 neuen und 8 gelöschten Zeilen
  1. 15 8
      exchanges/src/coinex_swap_rest.rs

+ 15 - 8
exchanges/src/coinex_swap_rest.rs

@@ -546,14 +546,21 @@ impl CoinexSwapRest {
         };
 
         // 读取响应的内容
-        let response = request_builder.send().await.unwrap();
-        let is_success = response.status().is_success(); // 先检查状态码
-        let text = response.text().await.unwrap();
-        let data_json: Value = serde_json::from_str(text.as_str()).unwrap();
-        return if is_success && data_json["code"].to_string() == "0"{
-            self.on_success_data(data_json["data"].clone())
-        } else {
-            self.on_error_data(&text, &url, &body)
+        let res = request_builder.send().await;
+        match res {
+            Ok(response) => {
+                let is_success = response.status().is_success(); // 先检查状态码
+                let text = response.text().await.unwrap();
+                let data_json: Value = serde_json::from_str(text.as_str()).unwrap();
+                return if is_success && data_json["code"].to_string() == "0"{
+                    self.on_success_data(data_json["data"].clone())
+                } else {
+                    self.on_error_data(&text, &url, &body)
+                }
+            },
+            Err(e) => {// 异常情况
+                self.on_error_data(&e.to_string(), &url, &body)
+            }
         }
     }