We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 486a8c7 + e46aadb commit 6163f47Copy full SHA for 6163f47
taos-ws/src/query/asyn.rs
@@ -321,7 +321,13 @@ async fn read_queries(
321
match frame {
322
Message::Text(text) => {
323
tracing::trace!("received json response: {text}",);
324
- let v: WsRecv = serde_json::from_str(&text).unwrap();
+ // 如果text 序列化失败,打印日志,继续处理下一个消息
325
+ let v = serde_json::from_str::<WsRecv>(&text);
326
+ if let Err(err) = v {
327
+ tracing::error!("failed to deserialize json text: {text}, error: {err:?}");
328
+ return ControlFlow::Continue(());
329
+ }
330
+ let v = v.unwrap();
331
let queries_sender = queries_sender.clone();
332
let ws2 = ws2.clone();
333
let (req_id, data, ok) = v.ok();
0 commit comments