Skip to content

Commit 83ac9e8

Browse files
committed
_
1 parent 9d1b0fe commit 83ac9e8

File tree

1 file changed

+10
-11
lines changed
  • v_exchanges/src/binance

1 file changed

+10
-11
lines changed

v_exchanges/src/binance/ws.rs

Lines changed: 10 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -50,24 +50,23 @@ impl ExchangeStream for TradesConnection {
5050
_ => unimplemented!(),
5151
};
5252
if trade.price == 0.0 || trade.qty_asset == 0.0 {
53-
warn_zeroed_trade(&content_event);
53+
fn warn_zeroed_trade(event: &adapters::generics::ws::ContentEvent, trade: Trade) {
54+
tracing::warn!(
55+
raw_json = %event.data,
56+
topic = %event.topic,
57+
event_type = %event.event_type,
58+
event_time = %event.time,
59+
"Binance sent a zero-valued trade, skipping.\nWas deserialized to: {trade:?}",
60+
);
61+
}
62+
warn_zeroed_trade(&content_event, trade);
5463
continue;
5564
}
5665
return Ok(trade);
5766
}
5867
}
5968
}
6069

61-
fn warn_zeroed_trade(event: &adapters::generics::ws::ContentEvent) {
62-
tracing::warn!(
63-
raw_json = %event.data,
64-
topic = %event.topic,
65-
event_type = %event.event_type,
66-
event_time = %event.time,
67-
"Binance sent a zero-valued trade, skipping"
68-
);
69-
}
70-
7170
#[serde_as]
7271
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize)]
7372
pub struct TradeEventPerp {

0 commit comments

Comments
 (0)