Skip to content

Commit 2ff6cfc

Browse files
pbeetspbeets
committed
style: apply cargo fmt
1 parent 690e0aa commit 2ff6cfc

File tree

13 files changed

+70
-82
lines changed

13 files changed

+70
-82
lines changed

‎examples/batch_orders.rs‎

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -184,16 +184,13 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
184184
if let Some(order) = &result.order {
185185
println!(
186186
" {} | CANCELED | reduced by: {} contracts",
187-
order.order_id,
188-
result.reduced_by
187+
order.order_id, result.reduced_by
189188
);
190189
canceled_count += 1;
191190
} else if let Some(error) = &result.error {
192191
println!(
193192
" {} | FAILED | {}: {}",
194-
result.order_id,
195-
error.code,
196-
error.message
193+
result.order_id, error.code, error.message
197194
);
198195
failed_count += 1;
199196
}

‎examples/candlesticks.rs‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -138,10 +138,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
138138
let yes_bid = format!("${:.2}", cents_to_dollars(candle.yes_bid.close));
139139
let yes_ask = format!("${:.2}", cents_to_dollars(candle.yes_ask.close));
140140

141-
println!(
142-
"{:<20} {:>12} {:>12}",
143-
timestamp, yes_bid, yes_ask
144-
);
141+
println!("{:<20} {:>12} {:>12}", timestamp, yes_bid, yes_ask);
145142
}
146143
}
147144
println!();

‎examples/events.rs‎

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
3434
println!("Total events returned: {}", events.events.len());
3535

3636
if !events.cursor.is_empty() {
37-
println!("Next cursor: {}...", &events.cursor[..events.cursor.len().min(20)]);
37+
println!(
38+
"Next cursor: {}...",
39+
&events.cursor[..events.cursor.len().min(20)]
40+
);
3841
}
3942

4043
println!();
@@ -72,7 +75,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
7275
if let Some(markets) = &event.markets {
7376
println!(" Markets ({}):", markets.len());
7477
for market in markets.iter().take(5) {
75-
println!(" {} | {} | YES ask: ${}", market.ticker, market.title, market.yes_ask_dollars);
78+
println!(
79+
" {} | {} | YES ask: ${}",
80+
market.ticker, market.title, market.yes_ask_dollars
81+
);
7682
}
7783
if markets.len() > 5 {
7884
println!(" ... and {} more markets", markets.len() - 5);
@@ -133,7 +139,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
133139
);
134140

135141
// Show pricing
136-
println!(" YES: ${} bid / ${} ask", market.yes_bid_dollars, market.yes_ask_dollars);
142+
println!(
143+
" YES: ${} bid / ${} ask",
144+
market.yes_bid_dollars, market.yes_ask_dollars
145+
);
137146
}
138147
}
139148
println!();

‎examples/historical.rs‎

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -36,15 +36,15 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
3636
for market in &markets.markets {
3737
println!(
3838
" {} | {:?} | result: {:?} | vol: {}",
39-
market.ticker,
40-
market.status,
41-
market.result,
42-
market.volume
39+
market.ticker, market.status, market.result, market.volume
4340
);
4441
}
4542

4643
if !markets.cursor.is_empty() {
47-
println!(" Next cursor: {}...", &markets.cursor[..markets.cursor.len().min(20)]);
44+
println!(
45+
" Next cursor: {}...",
46+
&markets.cursor[..markets.cursor.len().min(20)]
47+
);
4848
}
4949
println!();
5050

@@ -79,11 +79,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
7979
Ok(candles) => {
8080
println!(" {} candlesticks returned", candles.candlesticks.len());
8181
for candle in candles.candlesticks.iter().take(3) {
82-
let close = candle
83-
.price
84-
.close
85-
.as_deref()
86-
.unwrap_or("N/A");
82+
let close = candle.price.close.as_deref().unwrap_or("N/A");
8783
println!(
8884
" ts={} close=${} vol={}",
8985
candle.end_period_ts, close, candle.volume

‎examples/markets.rs‎

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
2525
let markets = client.get_markets().await?;
2626
println!("Total markets returned: {}", markets.markets.len());
2727
if !markets.cursor.is_empty() {
28-
println!("Next cursor: {}...", &markets.cursor[..markets.cursor.len().min(20)]);
28+
println!(
29+
"Next cursor: {}...",
30+
&markets.cursor[..markets.cursor.len().min(20)]
31+
);
2932
}
3033
println!();
3134

@@ -39,11 +42,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
3942
for market in &open_markets.markets {
4043
println!(
4144
" {} | {} | Vol: {}",
42-
market.ticker,
43-
market.title,
44-
market.volume
45+
market.ticker, market.title, market.volume
46+
);
47+
println!(
48+
" YES bid/ask: ${} / ${}",
49+
market.yes_bid_dollars, market.yes_ask_dollars
4550
);
46-
println!(" YES bid/ask: ${} / ${}", market.yes_bid_dollars, market.yes_ask_dollars);
4751
}
4852
println!();
4953

‎examples/orderbook_aggregator.rs‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -107,11 +107,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
107107
);
108108

109109
for market in &selected_markets {
110-
println!(
111-
" - {} (vol: {})",
112-
market.ticker,
113-
market.volume
114-
);
110+
println!(" - {} (vol: {})", market.ticker, market.volume);
115111
}
116112

117113
let market_tickers: Vec<String> = selected_markets.iter().map(|m| m.ticker.clone()).collect();

‎examples/rfq_verify.rs‎

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -106,10 +106,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
106106
};
107107
println!(
108108
" - {} | {} | {} | status: {}",
109-
rfq.id,
110-
rfq.market_ticker,
111-
size,
112-
rfq.status
109+
rfq.id, rfq.market_ticker, size, rfq.status
113110
);
114111
}
115112
println!();
@@ -153,10 +150,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
153150
for quote in &response.quotes {
154151
println!(
155152
" - {} | yes: {} / no: {} | status: {}",
156-
quote.id,
157-
quote.yes_bid_dollars,
158-
quote.no_bid_dollars,
159-
quote.status
153+
quote.id, quote.yes_bid_dollars, quote.no_bid_dollars, quote.status
160154
);
161155
}
162156
println!();

‎examples/stream_ticker.rs‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -74,11 +74,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
7474
);
7575

7676
for market in &selected_markets {
77-
println!(
78-
" - {} (vol: {})",
79-
market.ticker,
80-
market.volume
81-
);
77+
println!(" - {} (vol: {})", market.ticker, market.volume);
8278
}
8379

8480
let market_tickers: Vec<String> = selected_markets.iter().map(|m| m.ticker.clone()).collect();

‎examples/trading.rs‎

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
4545
println!("Selected market: {}", market.ticker);
4646

4747
println!("Title: {}", market.title);
48-
println!("Current YES: ${} bid / ${} ask", market.yes_bid_dollars, market.yes_ask_dollars);
48+
println!(
49+
"Current YES: ${} bid / ${} ask",
50+
market.yes_bid_dollars, market.yes_ask_dollars
51+
);
4952

5053
println!();
5154

@@ -277,7 +280,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
277280

278281
match client.get_queue_positions_with_params(params).await {
279282
Ok(response) => {
280-
println!("Orders with queue positions: {}", response.queue_positions.len());
283+
println!(
284+
"Orders with queue positions: {}",
285+
response.queue_positions.len()
286+
);
281287
for qp in response.queue_positions.iter().take(5) {
282288
println!(
283289
" {} | {} contracts ahead",

‎src/batch.rs‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -713,9 +713,7 @@ impl AggregatedCancelResponse {
713713
}
714714

715715
/// Returns an iterator over failed cancellations with their order_id and error.
716-
pub fn failed_orders(
717-
&self,
718-
) -> impl Iterator<Item = (&str, &crate::models::BatchOrderError)> {
716+
pub fn failed_orders(&self) -> impl Iterator<Item = (&str, &crate::models::BatchOrderError)> {
719717
self.orders
720718
.iter()
721719
.filter_map(|r| r.error.as_ref().map(|e| (r.order_id.as_str(), e)))

0 commit comments

Comments
 (0)