mqtt: subscribe

fooker · Mar 16, 2024 · 28e17a5 · 28e17a5
1 parent d681fa3
commit 28e17a5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/interface-mqtt/src/lib.rs b/interface-mqtt/src/lib.rs
@@ -66,17 +66,18 @@ impl Interface for MQTT<'_> {
 
         for input in introspection.inputs.values() {
             let topic = realm.topic(format!("input/{}/set", input.name));
-            topics.insert(topic, input);
 
-            client.subscribe(topic.to_owned(), QoS::AtLeastOnce).await?;
+            client.subscribe(topic.clone(), QoS::AtLeastOnce).await?;
             eprintln!("⇄ Subscribed to '{}' for input '{}' with type {}", topic, input.name, input.value_type);
+
+            topics.insert(topic, input);
         }
 
         while let Ok(event) = event_loop.poll().await {
             match event {
                 Event::Incoming(Incoming::Connect(_)) => {
                     for (topic, input) in &topics {
-                        client.subscribe(topic.to_owned(), QoS::AtLeastOnce).await?;
+                        client.subscribe(topic.clone(), QoS::AtLeastOnce).await?;
                         eprintln!("⇄ Subscribed to '{}' for input '{}' with type {}", topic, input.name, input.value_type);
                     }
                 }