|
|
@@ -419,17 +419,6 @@ where
|
|
|
}
|
|
|
};
|
|
|
|
|
|
- let batch_min_received_at = updates
|
|
|
- .price_feeds
|
|
|
- .iter()
|
|
|
- .filter_map(|u| u.received_at)
|
|
|
- .min();
|
|
|
- let batch_min_publish_time = updates
|
|
|
- .price_feeds
|
|
|
- .iter()
|
|
|
- .map(|u| u.price_feed.get_price_unchecked().publish_time)
|
|
|
- .min();
|
|
|
-
|
|
|
let batch_min_received_at = updates
|
|
|
.price_feeds
|
|
|
.iter()
|
|
|
@@ -455,7 +444,6 @@ where
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-
|
|
|
let message = serde_json::to_string(&ServerMessage::PriceUpdate {
|
|
|
price_feed: RpcPriceFeed::from_price_feed_update(
|
|
|
update,
|