Update z_pub_thr.rs

eclipse-zenoh · Nov 20, 2024 · 8a15f5f · 8a15f5f
1 parent 45039c9
commit 8a15f5f
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/examples/examples/z_pub_thr.rs b/examples/examples/z_pub_thr.rs
@@ -46,6 +46,12 @@ fn main() {
         .congestion_control(CongestionControl::Block)
         .priority(prio)
         .express(args.express)
+        .allowed_destination({
+            match args.remote {
+                true => zenoh::sample::Locality::Remote,
+                false => zenoh::sample::Locality::Any,
+            }
+        })
         .wait()
         .unwrap();
 
@@ -70,6 +76,9 @@ fn main() {
 
 #[derive(Parser, Clone, PartialEq, Eq, Hash, Debug)]
 struct Args {
+    /// remote-only locality for sending data
+    #[arg(short, long, default_value = "false")]
+    remote: bool,
     /// express for sending data
     #[arg(long, default_value = "false")]
     express: bool,