1 files changed, 11 insertions, 0 deletions
diff --git a/src/bin/cloudmqtt-test-client.rs b/src/bin/cloudmqtt-test-client.rs
index 8f58159..36f2d60 100644
--- a/src/bin/cloudmqtt-test-client.rs
+++ b/src/bin/cloudmqtt-test-client.rs
@@ -159,4 +159,15 @@ async fn main() {
             }
         }
     }
+
+    loop {
+        let _packet = match packet_stream.next().await {
+            Some(Ok(packet)) => packet,
+            None => {
+                eprintln!("Stream ended, stopping");
+                break;
+            }
+            Some(Err(error)) => print_error_and_quit(format!("Stream errored: {error}")),
+        };
+    }
 }