From f35e957dddbeda6ac3c25282f6c82b347dfa5502 Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Thu, 24 Apr 2025 05:55:24 +0800
Subject: [PATCH] style: fix clippy

---
 src/mito2/src/read/series_scan.rs | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/src/mito2/src/read/series_scan.rs b/src/mito2/src/read/series_scan.rs
index df5676b41d..40d42b2695 100644
--- a/src/mito2/src/read/series_scan.rs
+++ b/src/mito2/src/read/series_scan.rs
@@ -341,7 +341,7 @@ impl SeriesDistributor {
             for part_range in partition {
                 build_sources(
                     &self.stream_ctx,
-                    &part_range,
+                    part_range,
                     false,
                     &part_metrics,
                     range_builder_list.clone(),
@@ -386,7 +386,6 @@ impl SeriesDistributor {
             metrics.yield_cost += yield_start.elapsed();
         }
 
-        // todo: if not empty
         if !current_series.is_empty() {
             let yield_start = Instant::now();
             self.senders.send_batch(current_series).await?;
@@ -527,11 +526,9 @@ impl SenderList {
 
     async fn send_error(&self, error: Error) {
         let error = Arc::new(error);
-        for sender in &self.senders {
-            if let Some(sender) = sender {
-                let result = Err(error.clone()).context(ScanSeriesSnafu);
-                let _ = sender.send(result).await;
-            }
+        for sender in self.senders.iter().flatten() {
+            let result = Err(error.clone()).context(ScanSeriesSnafu);
+            let _ = sender.send(result).await;
         }
     }