fix

risingwavelabs · Oct 24, 2024 · f176ff2 · f176ff2
1 parent e57b8ff
commit f176ff2
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/connector/src/source/mqtt/enumerator/mod.rs b/src/connector/src/source/mqtt/enumerator/mod.rs
@@ -114,8 +114,7 @@ impl SplitEnumerator for MqttSplitEnumerator {
         let topics_clone = topics.clone();
         tokio::spawn(async move {
             while !stopped_clone.load(std::sync::atomic::Ordering::Relaxed) {
-                let a = eventloop.poll().await;
-                match a {
+                match eventloop.poll().await {
                     Ok(Event::Outgoing(Outgoing::Subscribe(_))) => {
                         connected_state_clone.set_is_connected(true);
                     }