fix examples and add test

Author: DenisBiryukov91

examples/z_advanced_pub.py

@@ -35,6 +35,7 @@ def main(conf: zenoh.Config, key: str, payload: str, history: int):
 
         print("Press CTRL-C to quit...")
         for idx in itertools.count():
+            time.sleep(1)
             buf = f"[{idx:4d}] {payload}"
             print(f"Putting Data ('{key}': '{buf}')...")
             pub.put(buf)
@@ -47,7 +48,7 @@ def main(conf: zenoh.Config, key: str, payload: str, history: int):
 
     import common
 
-    parser = argparse.ArgumentParser(prog="z_pub", description="zenoh pub example")
+    parser = argparse.ArgumentParser(prog="z_advanced_pub", description="zenoh advanced pub example")
     common.add_config_arguments(parser)
     parser.add_argument(
         "--key",
@@ -76,4 +77,4 @@ def main(conf: zenoh.Config, key: str, payload: str, history: int):
     args = parser.parse_args()
     conf = common.get_config_from_args(args)
 
-    main(conf, args.key, args.payload, args.history, args.iter, args.interval)
+    main(conf, args.key, args.payload, args.history)

examples/z_advanced_sub.py

@@ -55,7 +55,7 @@ def miss_listener(miss: Miss):
 
     import common
 
-    parser = argparse.ArgumentParser(prog="z_sub", description="zenoh sub example")
+    parser = argparse.ArgumentParser(prog="z_advanced_sub", description="zenoh advanced sub example")
     common.add_config_arguments(parser)
     parser.add_argument(
         "--key",

tests/examples_check.py

@@ -356,3 +356,31 @@ def test_z_sub_thr_z_pub_thr():
 
     assert not sub_thr.errors
     assert not pub_thr.errors
+
+
+def test_z_advanced_pub_z_advanced_sub():
+    """Test z_advanced_pub & z_advanced_sub."""
+    ## Run z_advanced_pub and z_advanced_sub
+    ## z_advanced_pub: Start publishing messages
+    pub = Pyrun("z_advanced_pub.py", ["--history=10"])
+    time.sleep(5) # wait 5 seconds to ensure that we miss few messages
+    sub = Pyrun("z_advanced_sub.py", [])
+    time.sleep(5)
+
+    if error := pub.interrupt():
+        pub.dbg()
+        pub.errors.append(error)
+    if error := sub.interrupt():
+        sub.dbg()
+        sub.errors.append(error)
+
+    sub_out = "".join(sub.stdout)
+    for i in range(0, 8):
+        if not (
+            F"Received SampleKind.PUT ('demo/example/zenoh-python-pub': '[   {i}] Pub from Python!')"
+            in sub_out
+        ):
+            sub.errors.append(F"z_advanced_sub didn't catch the {i}-th z_advanced_pub message")
+
+    assert not pub.errors
+    assert not sub.errors