Skip to content

Commit bfa6978

Browse files
committed
cargo fmt
1 parent a49eb48 commit bfa6978

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

jetstreamer-firehose/src/firehose.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3014,7 +3014,6 @@ async fn debug_epoch_720_slot_311173980_node_summary() {
30143014
}
30153015
}
30163016

3017-
30183017
#[tokio::test(flavor = "multi_thread")]
30193018
async fn test_firehose_epoch_850_has_logs() {
30203019
use std::sync::atomic::{AtomicU64, Ordering};

jetstreamer-firehose/src/index.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -757,9 +757,7 @@ impl CidOffsetIndex {
757757
.ok_or_else(|| {
758758
SlotOffsetIndexError::IndexFormatError(
759759
self.object.url().clone(),
760-
format!(
761-
"bucket data range overflow (offset {data_start}, len {data_len})"
762-
),
760+
format!("bucket data range overflow (offset {data_start}, len {data_len})"),
763761
)
764762
})?;
765763
let data = self.object.fetch_range(data_start, data_end, true).await?;
@@ -1754,5 +1752,4 @@ mod tests {
17541752
.expect("beta should be present");
17551753
assert_eq!(got, expected);
17561754
}
1757-
17581755
}

0 commit comments

Comments
 (0)