v0.18.21: format code

src/io/mod.rs

@@ -27,4 +27,7 @@ pub(crate) use writeback_file::WritebackFile;
 // caller — the targeted `#[allow]` keeps the re-export visible without
 // dragging the rest of the module under `dead_code`.
 #[allow(unused_imports)]
-pub use pipeline::{DEFAULT_PIPELINE_DEPTH, Flow, Pipeline, READ_PIPELINE_DEPTH, Sink, WRITE_PIPELINE_DEPTH, WRITE_THROUGH_DEPTH};
+pub use pipeline::{
+    DEFAULT_PIPELINE_DEPTH, Flow, Pipeline, READ_PIPELINE_DEPTH, Sink, WRITE_PIPELINE_DEPTH,
+    WRITE_THROUGH_DEPTH,
+};

src/io/pipeline.rs

@@ -155,10 +155,7 @@ impl<I: Send + 'static, R: Send + 'static> Pipeline<I, R> {
 
                 while let Ok(item) = rx.recv() {
                     if debug_enabled() {
-                            tracing::debug!(
-                                "Pipeline receive: item={}",
-                                std::any::type_name::<I>()
-                            );
+                        tracing::debug!("Pipeline receive: item={}", std::any::type_name::<I>());
                     }
 
                     let apply_start = std::time::Instant::now();
@@ -179,10 +176,7 @@ impl<I: Send + 'static, R: Send + 'static> Pipeline<I, R> {
                         }
                         Err(e) => {
                             if debug_enabled() {
-                                    tracing::debug!(
-                                        "Pipeline: apply error, stopping, err={:?}",
-                                        e
-                                    );
+                                tracing::debug!("Pipeline: apply error, stopping, err={:?}", e);
                             }
                             first_err = Some(e);
                         }