codefmt

alttch · Feb 24, 2024 · 6f92c38 · 6f92c38
1 parent 2542f75
commit 6f92c38
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 16 deletions.
diff --git a/src/cli.rs b/src/cli.rs
@@ -392,19 +392,17 @@ async fn main() {
             .unwrap();
         let client = Arc::new(client);
         tokio::spawn(async move {
-            loop {
-                signal(SignalKind::interrupt()).unwrap().recv().await;
-                client.bye().await.unwrap();
-                print!("{}[2J", 27 as char);
-                if let Ok(term) = std::env::var("TERM") {
-                    if term.starts_with("screen") {
-                        for s in &["reset", "cnorm"] {
-                            let _r = std::process::Command::new("tput").arg(s).spawn();
-                        }
+            signal(SignalKind::interrupt()).unwrap().recv().await;
+            client.bye().await.unwrap();
+            print!("{}[2J", 27 as char);
+            if let Ok(term) = std::env::var("TERM") {
+                if term.starts_with("screen") {
+                    for s in &["reset", "cnorm"] {
+                        let _r = std::process::Command::new("tput").arg(s).spawn();
                     }
                 }
-                std::process::exit(0);
             }
+            std::process::exit(0);
         });
         let mut last_refresh: Option<Instant> = None;
         let show_step = Duration::from_secs(1);
@@ -486,12 +484,10 @@ async fn main() {
             info!("Listening to {}...", topics.join(", "));
             client.subscribe_bulk(topics).await.unwrap();
             tokio::spawn(async move {
-                loop {
-                    signal(SignalKind::interrupt()).unwrap().recv().await;
-                    info!("terminating");
-                    client.bye().await.unwrap();
-                    std::process::exit(0);
-                }
+                signal(SignalKind::interrupt()).unwrap().recv().await;
+                info!("terminating");
+                client.bye().await.unwrap();
+                std::process::exit(0);
             });
             loop {
                 let message = data_channel.recv().await.unwrap();

diff --git a/src/server.rs b/src/server.rs
@@ -1603,6 +1603,7 @@ mod stats {
 
     use serde::Serialize;
     #[derive(Serialize, Debug, Clone, Default)]
+    #[allow(clippy::struct_field_names)]
     pub struct Counters {
         // counters
         c_sub_ops: u64,