Skip to content

Commit cf4d901

Browse files
committed
fixup! _
1 parent 5197dd5 commit cf4d901

File tree

1 file changed

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

1 file changed

+9
-10
lines changed

v_exchanges/src/binance/ws.rs

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,15 @@ impl ExchangeStream for TradesConnection {
5050
_ => unimplemented!(),
5151
};
5252
if trade.price == 0.0 || trade.qty_asset == 0.0 {
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+
}
5362
warn_zeroed_trade(&content_event, trade);
5463
continue;
5564
}
@@ -58,16 +67,6 @@ impl ExchangeStream for TradesConnection {
5867
}
5968
}
6069

61-
fn warn_zeroed_trade(event: &adapters::generics::ws::ContentEvent, trade: Trade) {
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.\nWas deserialized to: {trade:?}",
68-
);
69-
}
70-
7170
#[serde_as]
7271
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize)]
7372
pub struct TradeEventPerp {

0 commit comments

Comments
 (0)