Skip to content

Commit bb90626

Browse files
committed
Updated example code
1 parent ec3f2d6 commit bb90626

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

examples/ws.rs

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
use anyhow::Result;
2-
use binance_async::model::websocket::Subscription;
2+
use binance_async::model::websocket::{BinanceWebsocketMessage, Subscription};
33
use binance_async::BinanceWebsocket;
4+
use chrono::Local;
45
use futures::TryStreamExt;
56

67
#[tokio::main]
@@ -27,7 +28,13 @@ async fn main() -> Result<()> {
2728
}
2829

2930
while let Some(msg) = ws.try_next().await? {
30-
println!("\n\n{:#?}", msg)
31+
// println!("\n\n{:#?}", msg)
32+
33+
match msg {
34+
BinanceWebsocketMessage::Trade(trade) => println!("{:?}", trade),
35+
BinanceWebsocketMessage::Ping => println!("{:?}: {:?}", Local::now(), msg),
36+
_ => {}
37+
};
3138
}
3239

3340
Ok(())

0 commit comments

Comments
 (0)