From e8f13dc9ffdcf757a9be5e8fd494a3d90718b649 Mon Sep 17 00:00:00 2001
From: ppom <reaction@ppom.me>
Date: Fri, 8 Aug 2025 12:00:00 +0200
Subject: [PATCH] cargo fmt

---
 src/daemon/socket.rs | 9 ++-------
 src/daemon/stream.rs | 9 ++-------
 2 files changed, 4 insertions(+), 14 deletions(-)

diff --git a/src/daemon/socket.rs b/src/daemon/socket.rs
index 2caa04a..6fd8a26 100644
--- a/src/daemon/socket.rs
+++ b/src/daemon/socket.rs
@@ -119,10 +119,7 @@ fn handle_show_or_flush_order(
         .iter()
         // stream filtering
         .filter(|(stream, _)| {
-            stream_name.is_none()
-                || stream_name
-                    .clone()
-                    .is_some_and(|name| name == stream.name)
+            stream_name.is_none() || stream_name.clone().is_some_and(|name| name == stream.name)
         })
         .fold(BTreeMap::new(), |mut acc, (stream, filter_manager)| {
             let inner_map = filter_manager
@@ -130,9 +127,7 @@ fn handle_show_or_flush_order(
                 // filter filtering
                 .filter(|(filter, _)| {
                     filter_name.is_none()
-                        || filter_name
-                            .clone()
-                            .is_some_and(|name| name == filter.name)
+                        || filter_name.clone().is_some_and(|name| name == filter.name)
                 })
                 // pattern filtering
                 .filter(|(filter, _)| {
diff --git a/src/daemon/stream.rs b/src/daemon/stream.rs
index ab464be..ac2d46a 100644
--- a/src/daemon/stream.rs
+++ b/src/daemon/stream.rs
@@ -90,11 +90,7 @@ impl StreamManager {
         {
             Ok(child) => child,
             Err(err) => {
-                error!(
-                    "could not execute stream {} cmd: {}",
-                    self.stream.name,
-                    err
-                );
+                error!("could not execute stream {} cmd: {}", self.stream.name, err);
                 return;
             }
         };
@@ -183,8 +179,7 @@ impl StreamManager {
                 Some(Err(err)) => {
                     error!(
                         "impossible to read output from stream {}: {}",
-                        self.stream.name,
-                        err
+                        self.stream.name, err
                     );
                     return;
                 }