Merge #147

147: Add loop at end of main() r=TheNeikos a=matthiasbeyer

Extracted from #133.

This is necessary to keep the default-behaviour of the executable if no commands are passed.


Co-authored-by: Matthias Beyer <mail@beyermatthias.de>

1 files changed, 11 insertions, 0 deletions

diff --git a/src/bin/cloudmqtt-test-client.rs b/src/bin/cloudmqtt-test-client.rs
index 9265aa0..588c0e9 100644
--- a/src/bin/cloudmqtt-test-client.rs
+++ b/src/bin/cloudmqtt-test-client.rs
@@ -149,4 +149,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}")),
+        };
+    }
 }