style: run (patched) rustfmt

I was originally perplexed as to why the crate wasn't already formatted,
but quickly found out why... Though the PR seems to have languished for
some time, I've run a patched version of rustfmt that completes without
crashing: rust-lang/rustfmt#6396

Author: TheLostLambda

examples/async_mzcat.rs

@@ -48,7 +48,8 @@ async fn scan_file(reader: &mut mzml::AsyncMzMLReader<fs::File>) {
 #[tokio::main(flavor = "multi_thread", worker_threads = 10)]
 async fn main() -> io::Result<()> {
     let path = path::PathBuf::from(
-        env::args().nth(1)
+        env::args()
+            .nth(1)
             .expect("Please pass an MS data file path"),
     );
     if let Some(ext) = path.extension() {

examples/get_scan_by.rs

@@ -34,8 +34,16 @@ fn main() -> io::Result<()> {
     };
 
     // dbg!(spectrum);
-    println!("ID: {}; Index: {}; Time: {}", spectrum.id(), spectrum.index(), spectrum.start_time());
-    println!("Num data points: {}", spectrum.raw_arrays().unwrap().mzs().unwrap().len());
+    println!(
+        "ID: {}; Index: {}; Time: {}",
+        spectrum.id(),
+        spectrum.index(),
+        spectrum.start_time()
+    );
+    println!(
+        "Num data points: {}",
+        spectrum.raw_arrays().unwrap().mzs().unwrap().len()
+    );
 
     Ok(())
 }

examples/mzconvert.rs

@@ -2,7 +2,11 @@ use std::any::Any;
 use std::fs::File;
 use std::io;
 use std::path::PathBuf;
-use std::sync::{mpsc::sync_channel, Arc, atomic::{AtomicU64, Ordering as AtomicOrdering}};
+use std::sync::{
+    atomic::{AtomicU64, Ordering as AtomicOrdering},
+    mpsc::sync_channel,
+    Arc,
+};
 use std::thread;
 use std::time;
 
@@ -32,9 +36,11 @@ fn compression_parser(compression: &str) -> Result<BinaryCompressionType, String
         compression.to_string()
     };
 
-    BinaryCompressionType::COMPRESSION_METHODS.iter().find(|x| {
-        x.as_param().unwrap().name() == compression
-    }).copied().ok_or_else(|| compression.to_string())
+    BinaryCompressionType::COMPRESSION_METHODS
+        .iter()
+        .find(|x| x.as_param().unwrap().name() == compression)
+        .copied()
+        .ok_or_else(|| compression.to_string())
 }
 
 #[derive(Debug, Clone, Parser)]
@@ -44,7 +50,7 @@ pub struct MZConvert {
     #[arg()]
     pub outpath: String,
 
-    #[arg(short='b', long, default_value_t=8192)]
+    #[arg(short = 'b', long, default_value_t = 8192)]
     pub buffer_size: usize,
 
     #[arg(long, value_parser=compression_parser, default_value="zlib compression")]
@@ -91,7 +97,7 @@ impl MZConvert {
         mut writer: W,
     ) -> io::Result<()> {
         let (send, recv) = sync_channel(self.buffer_size);
-        let buffered= Arc::new(AtomicU64::default());
+        let buffered = Arc::new(AtomicU64::default());
         let buffered_w = Arc::clone(&buffered);
         let reader_handle = thread::spawn(move || {
             reader.enumerate().for_each(|(i, s)| {
@@ -111,9 +117,10 @@ impl MZConvert {
             for s in recv.iter() {
                 let i = s.index();
                 buffered_w.fetch_sub(1, AtomicOrdering::SeqCst);
-                writer.write_owned(s).inspect_err(|e| {
-                    log::error!("Failed to write spectrum {i}: {e}")
-                }).unwrap();
+                writer
+                    .write_owned(s)
+                    .inspect_err(|e| log::error!("Failed to write spectrum {i}: {e}"))
+                    .unwrap();
             }
             writer.close().unwrap();
         });
@@ -190,7 +197,6 @@ impl MZConvert {
                     self.ion_mobility_compression,
                 );
             }
-
         }
     }
 }
@@ -251,7 +257,7 @@ impl MassSpectrometryReadWriteProcess<CentroidPeak, DeconvolutedPeak> for MZConv
                 Default::default()
             } else {
                 info!("Computing checksum for {}", pb.display());
-                
+
                 checksum_file(&pb)?
             };
             let has_already = reader

examples/mzinfo.rs

@@ -22,7 +22,7 @@ struct MSDataFileSummary {
     pub charge_table: HashMap<i32, usize>,
     pub peak_charge_table: HashMap<u8, HashMap<i32, usize>>,
     pub peak_mode_table: HashMap<SignalContinuity, usize>,
-    pub has_ion_mobility: bool
+    pub has_ion_mobility: bool,
 }
 
 impl Default for MSDataFileSummary {
@@ -112,11 +112,10 @@ impl MSDataFileSummary {
         let start = time::Instant::now();
         let (sender, receiver) = sync_channel(2usize.pow(12));
         let read_handle = spawn(move || {
-            reader.into_iter()
+            reader
+                .into_iter()
                 .enumerate()
-                .for_each(|(i, scan)| {
-                    sender.send((i, scan)).unwrap()
-                });
+                .for_each(|(i, scan)| sender.send((i, scan)).unwrap());
         });
         let i = receiver.iter().fold(0, |_, (i, scan)| {
             if i % 10000 == 0 && i > 0 {
@@ -134,7 +133,10 @@ impl MSDataFileSummary {
         read_handle.join().unwrap();
         let end = time::Instant::now();
         let elapsed = end - start;
-        println!("{:0.3} seconds elapsed, handled {i} spectra", elapsed.as_secs_f64());
+        println!(
+            "{:0.3} seconds elapsed, handled {i} spectra",
+            elapsed.as_secs_f64()
+        );
     }
 
     pub fn write_out(&self) {

src/io/compression.rs

@@ -115,4 +115,4 @@ mod test {
         assert!(buf.contains("controllerType=0 controllerNumber=1 scan=1"));
         Ok(())
     }
-}
+}