Remove a sender

wipbar · Jul 12, 2024 · 9eeb7ed · 9eeb7ed
1 parent 864a6cc
commit 9eeb7ed
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/mqtt.rs b/src/mqtt.rs
@@ -27,8 +27,6 @@ impl<F: Fn() -> Config + std::marker::Send + 'static> Listener<F> {
                 .subscribe(format!("screens/{}", id), rumqttc::QoS::AtLeastOnce)
                 .unwrap();
 
-            let sender = self.sender.clone();
-
             for event in connection.iter() {
                 println!("{:?}", event);
 
@@ -44,7 +42,7 @@ impl<F: Fn() -> Config + std::marker::Send + 'static> Listener<F> {
                             continue 'outer;
                         }
 
-                        sender.send(command).unwrap();
+                        self.sender.send(command).unwrap();
                     }
                 }
             }