runtime example now stops and cleans the nodes when receiving a ctrl-c

Signed-off-by: gabrik <gabriele.baldoni@gmail.com>

Author: gabrik

runtime/Cargo.toml

@@ -6,6 +6,7 @@ edition = "2018"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+async-ctrlc ={version = "1.2.0", features = ["stream"]}
 async-std = { version = "=1.10.0", features = ["attributes"] }
 zenoh-flow = { git = "https://github.com/eclipse-zenoh/zenoh-flow.git", branch = "master" }
 zenoh = { git = "https://github.com/eclipse-zenoh/zenoh.git", branch = "master"}

runtime/src/main.rs

@@ -13,6 +13,8 @@
 
 // TODO: this should become a deamon.
 
+use async_ctrlc::CtrlC;
+use async_std::prelude::StreamExt;
 use clap::Parser;
 use std::convert::TryFrom;
 use std::fs::{File, *};
@@ -115,5 +117,52 @@ async fn main() {
         instance.start_node(id).await.unwrap()
     }
 
-    let () = std::future::pending().await;
+    let ctrlc = CtrlC::new().expect("Unable to create Ctrl-C handler");
+    let mut stream = ctrlc.enumerate().take(1);
+    stream.next().await;
+    log::trace!("Received Ctrl-C start teardown");
+
+    // Stopping nodes
+    let sources = instance.get_sources();
+    for id in &sources {
+        instance.stop_node(id).await.unwrap()
+    }
+
+    let mut sinks = instance.get_sinks();
+    for id in sinks.drain(..) {
+        instance.stop_node(&id).await.unwrap()
+    }
+
+    let mut operators = instance.get_operators();
+    for id in operators.drain(..) {
+        instance.stop_node(&id).await.unwrap()
+    }
+
+    let mut connectors = instance.get_connectors();
+    for id in connectors.drain(..) {
+        instance.stop_node(&id).await.unwrap()
+    }
+
+    //  cleaning nodes
+    let sources = instance.get_sources();
+    for id in &sources {
+        instance.clean_node(id).await.unwrap()
+    }
+
+    let mut sinks = instance.get_sinks();
+    for id in sinks.drain(..) {
+        instance.clean_node(&id).await.unwrap()
+    }
+
+    let mut operators = instance.get_operators();
+    for id in operators.drain(..) {
+        instance.clean_node(&id).await.unwrap()
+    }
+
+    let mut connectors = instance.get_connectors();
+    for id in connectors.drain(..) {
+        instance.clean_node(&id).await.unwrap()
+    }
+
+    log::trace!("Bye!");
 }