better serde error handling
This commit is contained in:
+9
-2
@@ -21,8 +21,15 @@ async fn main() -> anyhow::Result<()> {
|
|||||||
while let Some(msg) = ws.next().await {
|
while let Some(msg) = ws.next().await {
|
||||||
let msg = msg?;
|
let msg = msg?;
|
||||||
if let tokio_tungstenite::tungstenite::Message::Text(text) = msg {
|
if let tokio_tungstenite::tungstenite::Message::Text(text) = msg {
|
||||||
let token: types::PumpDevEvent = serde_json::from_str(&text)?;
|
match serde_json::from_str::<types::PumpDevEvent>(&text) {
|
||||||
println!("{:?}", token);
|
Ok(event) => {
|
||||||
|
println!("{:?}", event);
|
||||||
|
}
|
||||||
|
|
||||||
|
Err(err) => {
|
||||||
|
log::error!("{err}");
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Ok(())
|
Ok(())
|
||||||
|
|||||||
Reference in New Issue
Block a user