style: use variable

ahdark-services · Apr 7, 2024 · b9541a1 · b9541a1
1 parent 4bc7bb3
commit b9541a1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/rust-common/Cargo.toml b/rust-common/Cargo.toml
@@ -22,7 +22,7 @@ teloxide = { workspace = true }
 redis = { workspace = true }
 lapin = { workspace = true }
 log = { workspace = true }
-futures = { version = "0.3", features = [] }
+futures = { version = "0.3", features = ["default"] }
 serde_json = { version = "1.0.114", features = [] }
 async-stream = "0.3.5"
 reqwest = "0.12"
diff --git a/rust-common/src/bot/channel.rs b/rust-common/src/bot/channel.rs
@@ -26,7 +26,9 @@ impl<'a> AsUpdateStream<'a> for MqUpdateListener {
 
     fn as_stream(&'a mut self) -> Self::Stream {
         let flag = self.flag.clone();
-        Box::pin(self.consumer.clone().filter_map(move |delivery| {
+        let consumer = self.consumer.clone();
+
+        Box::pin(consumer.filter_map(move |delivery| {
             assert!(!flag.is_stopped(), "Update listener stopped");
             if self.consumer.state() != lapin::ConsumerState::Active
                 && self.consumer.state() != lapin::ConsumerState::ActiveWithDelegate
@@ -56,8 +58,7 @@ impl<'a> AsUpdateStream<'a> for MqUpdateListener {
                         None
                     }
                 }
-            }
-            .boxed()
+            }.boxed()
         }))
     }
 }