Restore examples

eclipse-zenoh · Dec 4, 2024 · bceabb1 · bceabb1
1 parent 30341ff
commit bceabb1
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 18 deletions.
diff --git a/examples/examples/z_pub_thr.rs b/examples/examples/z_pub_thr.rs
@@ -43,7 +43,7 @@ fn main() {
 
     let publisher = session
         .declare_publisher("test/thr")
-        .congestion_control(CongestionControl::Drop)
+        .congestion_control(CongestionControl::Block)
         .priority(prio)
         .express(args.express)
         .wait()

diff --git a/examples/examples/z_sub.rs b/examples/examples/z_sub.rs
@@ -1,5 +1,3 @@
-use std::time::Duration;
-
 //
 // Copyright (c) 2023 ZettaScale Technology
 //
@@ -38,21 +36,17 @@ async fn main() {
             .try_to_string()
             .unwrap_or_else(|e| e.to_string().into());
 
-        // print!(
-        //     ">> [Subscriber] Received {} ('{}': '{}')",
-        //     sample.kind(),
-        //     sample.key_expr().as_str(),
-        //     payload
-        // );
-        // if let Some(att) = sample.attachment() {
-        //     let att = att.try_to_string().unwrap_or_else(|e| e.to_string().into());
-        //     print!(" ({})", att);
-        // }
-        // println!();
-        print!(".");
-        use std::io::Write;
-        std::io::stdout().flush().unwrap();
-        tokio::time::sleep(Duration::from_millis(100)).await;
+        print!(
+            ">> [Subscriber] Received {} ('{}': '{}')",
+            sample.kind(),
+            sample.key_expr().as_str(),
+            payload
+        );
+        if let Some(att) = sample.attachment() {
+            let att = att.try_to_string().unwrap_or_else(|e| e.to_string().into());
+            print!(" ({})", att);
+        }
+        println!();
     }
 }