tidy

foxglove · Jan 5, 2025 · ba1ae63 · ba1ae63
1 parent efdd0b7
commit ba1ae63
Showing 1 changed file with 12 additions and 15 deletions.
diff --git a/rust/src/sans_io/read.rs b/rust/src/sans_io/read.rs
@@ -556,14 +556,13 @@ impl LinearReader {
                                 self.currently_reading = ChunkRecord;
                                 continue;
                             }
-                            if matches!(
-                                decompress!(
-                                    uncompressed_len,
-                                    &mut state.compressed_remaining,
-                                    decompressor
-                                ),
-                                None
-                            ) {
+                            if decompress!(
+                                uncompressed_len,
+                                &mut state.compressed_remaining,
+                                decompressor
+                            )
+                            .is_none()
+                            {
                                 return Some(Err(McapError::UnexpectedEoc));
                             }
                         }
@@ -612,10 +611,9 @@ impl LinearReader {
                             let len = check!(len_as_usize(u64::from_le_bytes(
                                 opcode_len_buf[1..9].try_into().unwrap(),
                             )));
-                            if matches!(
-                                decompress!(9 + len, &mut state.compressed_remaining, decompressor),
-                                None
-                            ) {
+                            if decompress!(9 + len, &mut state.compressed_remaining, decompressor)
+                                .is_none()
+                            {
                                 return Some(Err(McapError::UnexpectedEoc));
                             }
                             self.decompressed_content.mark_read(9);
@@ -1130,11 +1128,10 @@ mod tests {
             .expect("failed to open file");
         let blocksize: usize = 1024;
         let mut reader = LinearReader::new();
+        // iterate through the file to ensure that the iterator does not hang.
         while let Some(action) = reader.next_action() {
             match action.expect("failed to get next action") {
-                ReadAction::GetRecord { data: _, opcode } => {
-                    print!("{},", opcode);
-                }
+                ReadAction::GetRecord { .. } => {}
                 ReadAction::NeedMore(_) => {
                     let read = f
                         .read(reader.insert(blocksize))