Skip to content

Commit 7ce2c7a

Browse files
committed
chore(fmt): cargo fmt streams per rustfmt 1.95 (CI gate)
Wave F stream scaffolds (qualia.rs / inference.rs / splat_field.rs) needed rustfmt 1.95 reformatting per the CI fmt gate. Same family of single-line / multi-line layout adjustments that hit lance-graph PRs #383 / #384 / #386. Pure mechanical reformat via `cargo fmt`. No behavior change; 18/18 stream tests still pass.
1 parent 2a1a1e3 commit 7ce2c7a

3 files changed

Lines changed: 14 additions & 37 deletions

File tree

src/hpc/stream/inference.rs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -129,11 +129,7 @@ mod tests {
129129

130130
#[test]
131131
fn test_inference_stream_yields_all() {
132-
let rows = vec![
133-
InferenceRow(0),
134-
InferenceRow(1),
135-
InferenceRow(2),
136-
];
132+
let rows = vec![InferenceRow(0), InferenceRow(1), InferenceRow(2)];
137133
let stream = InferenceStream::new(&rows);
138134
let collected: Vec<_> = stream.collect();
139135
assert_eq!(collected.len(), 3);
@@ -218,6 +214,6 @@ mod tests {
218214
assert_eq!(stream.remaining(), 2);
219215
let first = stream.next().unwrap();
220216
assert_eq!(first.0, 0);
221-
assert_eq!(first.1.0, 10);
217+
assert_eq!(first.1 .0, 10);
222218
}
223219
}

src/hpc/stream/qualia.rs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -128,12 +128,7 @@ mod tests {
128128
/// Stream over N rows must yield exactly N items.
129129
#[test]
130130
fn test_stream_yields_all_rows() {
131-
let rows = vec![
132-
QualiaI4Row(0xAA),
133-
QualiaI4Row(0xBB),
134-
QualiaI4Row(0xCC),
135-
QualiaI4Row(0xDD),
136-
];
131+
let rows = vec![QualiaI4Row(0xAA), QualiaI4Row(0xBB), QualiaI4Row(0xCC), QualiaI4Row(0xDD)];
137132
let stream = QualiaStream::new(&rows);
138133
let collected: Vec<(usize, &QualiaI4Row)> = stream.collect();
139134
assert_eq!(collected.len(), rows.len());

src/hpc/stream/splat_field.rs

Lines changed: 11 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -87,10 +87,7 @@ impl<'a> SplatFieldStream<'a> {
8787
///
8888
/// Consumes `self` (the `SplatFieldStream` is itself an `Iterator`) and
8989
/// returns a lazy `impl Iterator` — no allocation.
90-
pub fn filter_energy_above(
91-
self,
92-
threshold: f32,
93-
) -> impl Iterator<Item = (usize, &'a SplatField)> {
90+
pub fn filter_energy_above(self, threshold: f32) -> impl Iterator<Item = (usize, &'a SplatField)> {
9491
self.filter(move |(_, s)| s.energy > threshold)
9592
}
9693
}
@@ -132,7 +129,12 @@ mod tests {
132129
use std::mem;
133130

134131
fn make_splat(mean: u32, variance: f32, energy: f32, generation: u32) -> SplatField {
135-
SplatField { mean, variance, energy, generation }
132+
SplatField {
133+
mean,
134+
variance,
135+
energy,
136+
generation,
137+
}
136138
}
137139

138140
/// Empty slice → stream yields nothing immediately.
@@ -149,11 +151,7 @@ mod tests {
149151
/// Stream over N rows must yield exactly N items with matching indices.
150152
#[test]
151153
fn test_splat_stream_yields_all() {
152-
let rows = vec![
153-
make_splat(0, 1.0, 0.1, 1),
154-
make_splat(1, 2.0, 0.5, 2),
155-
make_splat(2, 0.5, 2.0, 3),
156-
];
154+
let rows = vec![make_splat(0, 1.0, 0.1, 1), make_splat(1, 2.0, 0.5, 2), make_splat(2, 0.5, 2.0, 3)];
157155
let stream = SplatFieldStream::new(&rows);
158156
let collected: Vec<(usize, &SplatField)> = stream.collect();
159157
assert_eq!(collected.len(), 3);
@@ -183,16 +181,8 @@ mod tests {
183181
/// and field packing (4 × 4-byte fields with no hidden padding).
184182
#[test]
185183
fn test_splat_field_size_16b() {
186-
assert_eq!(
187-
mem::size_of::<SplatField>(),
188-
16,
189-
"SplatField must be exactly 16 bytes (4 × 4B fields, align(16))"
190-
);
191-
assert_eq!(
192-
mem::align_of::<SplatField>(),
193-
16,
194-
"SplatField alignment must be 16"
195-
);
184+
assert_eq!(mem::size_of::<SplatField>(), 16, "SplatField must be exactly 16 bytes (4 × 4B fields, align(16))");
185+
assert_eq!(mem::align_of::<SplatField>(), 16, "SplatField alignment must be 16");
196186
}
197187

198188
/// `remaining()` must decrement by 1 with each `next()` call.
@@ -219,11 +209,7 @@ mod tests {
219209
/// After `reset()`, the stream replays all rows from index 0.
220210
#[test]
221211
fn test_reset_restarts() {
222-
let rows = vec![
223-
make_splat(10, 1.0, 0.3, 1),
224-
make_splat(20, 2.0, 0.6, 2),
225-
make_splat(30, 3.0, 0.9, 3),
226-
];
212+
let rows = vec![make_splat(10, 1.0, 0.3, 1), make_splat(20, 2.0, 0.6, 2), make_splat(30, 3.0, 0.9, 3)];
227213
let mut stream = SplatFieldStream::new(&rows);
228214
// Consume everything
229215
while stream.next().is_some() {}

0 commit comments

Comments
 (0)