diff --git a/src/mqtt.rs b/src/mqtt.rs
index 6c8e6c7..179f47f 100644
--- a/src/mqtt.rs
+++ b/src/mqtt.rs
@@ -103,7 +103,7 @@ impl<'a> MqttClient<'a> {
             client.disconnect(None);
         });
         while let Some(msg) = self.stream.next().await {
-            let Some(msg) = msg else {continue};
+            let Some(msg) = msg else {break};
             trace!("Received message: {:?}", msg);
             for m in self.topics.matches(msg.topic()) {
                 match m.1 {