Update rest of examples

Author: silvestrpredko

rumqttd/examples/external_auth.rs

@@ -32,9 +32,15 @@ fn main() {
     //     true
     // });
 
-    let mut broker = Broker::new(config);
+    let _guard = Broker::new(config).start().unwrap().drop_guard();
 
-    broker.start().unwrap();
+    let (tx, rx) = flume::bounded::<()>(1);
+    ctrlc::set_handler(move || {
+        let _ = tx.send(());
+    })
+    .expect("Error setting Ctrl-C handler");
+
+    rx.recv().expect("Could not receive Ctrl-C signal");
 }
 
 async fn auth(_client_id: String, _username: String, _password: String) -> bool {

rumqttd/examples/meters.rs

@@ -15,7 +15,7 @@ fn main() {
 
     dbg!(&config);
 
-    let mut broker = Broker::new(config);
+    let broker = Broker::new(config);
     let meters = broker.meters().unwrap();
 
     let (mut link_tx, mut link_rx) = broker.link("consumer").unwrap();
@@ -59,11 +59,7 @@ fn main() {
         });
     }
 
-    thread::spawn(move || {
-        if let Err(e) = broker.start() {
-            println!("Broker stopped: {e}");
-        }
-    });
+    let _guard = broker.start().unwrap().drop_guard();
     thread::sleep(Duration::from_secs(2));
 
     loop {

rumqttd/examples/singlenode.rs

@@ -1,7 +1,5 @@
 use rumqttd::{Broker, Config, Notification};
 
-use std::thread;
-
 fn main() {
     let builder = tracing_subscriber::fmt()
         .pretty()
@@ -25,11 +23,9 @@ fn main() {
 
     dbg!(&config);
 
-    let mut broker = Broker::new(config);
+    let broker = Broker::new(config);
     let (mut link_tx, mut link_rx) = broker.link("singlenode").unwrap();
-    thread::spawn(move || {
-        broker.start().unwrap();
-    });
+    let _guard = broker.start().unwrap().drop_guard();
 
     link_tx.subscribe("#").unwrap();