diff --git a/docs/pubsub.rst b/docs/pubsub.rst
index c7d67f8f..9611d8c1 100644
--- a/docs/pubsub.rst
+++ b/docs/pubsub.rst
@@ -65,6 +65,7 @@ Subscriber example with non-blocking stream interface:
 .. code-block:: c++
 
     #include "zenoh.hxx"
+    #include <chrono>
     #include <iostream>
     #include <thread>
 
diff --git a/examples/universal/z_get_channel_non_blocking.cxx b/examples/universal/z_get_channel_non_blocking.cxx
index 489325bb..aeed2917 100644
--- a/examples/universal/z_get_channel_non_blocking.cxx
+++ b/examples/universal/z_get_channel_non_blocking.cxx
@@ -14,6 +14,7 @@
 #include <stdio.h>
 #include <string.h>
 
+#include <chrono>
 #include <condition_variable>
 #include <iostream>
 #include <thread>
diff --git a/tests/universal/network/liveliness.cxx b/tests/universal/network/liveliness.cxx
index 67668874..3a2ec0eb 100644
--- a/tests/universal/network/liveliness.cxx
+++ b/tests/universal/network/liveliness.cxx
@@ -12,6 +12,7 @@
 //   ZettaScale Zenoh Team, <zenoh@zettascale.tech>
 //
 
+#include <chrono>
 #include <thread>
 #include <unordered_set>
 
diff --git a/tests/universal/network/pub_sub.cxx b/tests/universal/network/pub_sub.cxx
index 40ac914e..6e06217e 100644
--- a/tests/universal/network/pub_sub.cxx
+++ b/tests/universal/network/pub_sub.cxx
@@ -12,6 +12,7 @@
 //   ZettaScale Zenoh Team, <zenoh@zettascale.tech>
 //
 
+#include <chrono>
 #include <thread>
 
 #include "zenoh.hxx"
@@ -118,7 +119,9 @@ void put_sub_fifo_channel(Talloc& alloc) {
 
     std::this_thread::sleep_for(1s);
 
-    auto subscriber = session2.declare_subscriber(ke, channels::FifoChannel(16));
+    std::vector<Subscriber<channels::FifoChannel::HandlerType<Sample>>> subscribers;
+    subscribers.push_back(session2.declare_subscriber(ke, channels::FifoChannel(16)));
+    subscribers.push_back(session2.declare_subscriber(ke, channels::FifoChannel(16)));
 
     std::this_thread::sleep_for(1s);
 
@@ -127,24 +130,28 @@ void put_sub_fifo_channel(Talloc& alloc) {
 
     std::this_thread::sleep_for(1s);
 
-    auto res = subscriber.handler().recv();
-    assert(std::holds_alternative<Sample>(res));
-    assert(std::get<Sample>(res).get_keyexpr() == "zenoh/test");
-    assert(std::get<Sample>(res).get_payload().as_string() == "first");
-    res = subscriber.handler().try_recv();
-    assert(std::holds_alternative<Sample>(res));
-    assert(std::get<Sample>(res).get_keyexpr() == "zenoh/test");
-    assert(std::get<Sample>(res).get_payload().as_string() == "second");
-
-    res = subscriber.handler().try_recv();
-    assert(std::holds_alternative<channels::RecvError>(res));
-    assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_NODATA);
+    for (const auto& subscriber : subscribers) {
+        auto res = subscriber.handler().recv();
+        assert(std::holds_alternative<Sample>(res));
+        assert(std::get<Sample>(res).get_keyexpr() == "zenoh/test");
+        assert(std::get<Sample>(res).get_payload().as_string() == "first");
+        res = subscriber.handler().try_recv();
+        assert(std::holds_alternative<Sample>(res));
+        assert(std::get<Sample>(res).get_keyexpr() == "zenoh/test");
+        assert(std::get<Sample>(res).get_payload().as_string() == "second");
+
+        res = subscriber.handler().try_recv();
+        assert(std::holds_alternative<channels::RecvError>(res));
+        assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_NODATA);
+    }
 
     /// after session close subscriber handler should become disconnected
     session2.close();
-    res = subscriber.handler().recv();
-    assert(std::holds_alternative<channels::RecvError>(res));
-    assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_DISCONNECTED);
+    for (const auto& subscriber : subscribers) {
+        auto res = subscriber.handler().recv();
+        assert(std::holds_alternative<channels::RecvError>(res));
+        assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_DISCONNECTED);
+    }
 }
 
 template <typename Talloc>
@@ -155,7 +162,9 @@ void put_sub_ring_channel(Talloc& alloc) {
 
     std::this_thread::sleep_for(1s);
 
-    auto subscriber = session2.declare_subscriber(ke, channels::RingChannel(1));
+    std::vector<Subscriber<channels::RingChannel::HandlerType<Sample>>> subscribers;
+    subscribers.push_back(session2.declare_subscriber(ke, channels::RingChannel(1)));
+    subscribers.push_back(session2.declare_subscriber(ke, channels::RingChannel(1)));
 
     std::this_thread::sleep_for(1s);
 
@@ -164,20 +173,24 @@ void put_sub_ring_channel(Talloc& alloc) {
 
     std::this_thread::sleep_for(1s);
 
-    auto res = subscriber.handler().recv();
-    assert(std::holds_alternative<Sample>(res));
-    assert(std::get<Sample>(res).get_keyexpr() == "zenoh/test");
-    assert(std::get<Sample>(res).get_payload().as_string() == "second");
+    for (const auto& subscriber : subscribers) {
+        auto res = subscriber.handler().recv();
+        assert(std::holds_alternative<Sample>(res));
+        assert(std::get<Sample>(res).get_keyexpr() == "zenoh/test");
+        assert(std::get<Sample>(res).get_payload().as_string() == "second");
 
-    res = subscriber.handler().try_recv();
-    assert(std::holds_alternative<channels::RecvError>(res));
-    assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_NODATA);
+        res = subscriber.handler().try_recv();
+        assert(std::holds_alternative<channels::RecvError>(res));
+        assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_NODATA);
+    }
 
     /// after session close subscriber handler should become disconnected
     session2.close();
-    res = subscriber.handler().recv();
-    assert(std::holds_alternative<channels::RecvError>(res));
-    assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_DISCONNECTED);
+    for (const auto& subscriber : subscribers) {
+        auto res = subscriber.handler().recv();
+        assert(std::holds_alternative<channels::RecvError>(res));
+        assert(std::get<channels::RecvError>(res) == channels::RecvError::Z_DISCONNECTED);
+    }
 }
 
 template <typename Talloc, bool share_alloc = true>
diff --git a/tests/universal/network/queryable_get.cxx b/tests/universal/network/queryable_get.cxx
index b2916f9b..e43e602f 100644
--- a/tests/universal/network/queryable_get.cxx
+++ b/tests/universal/network/queryable_get.cxx
@@ -12,6 +12,7 @@
 //   ZettaScale Zenoh Team, <zenoh@zettascale.tech>
 //
 
+#include <chrono>
 #include <thread>
 
 #include "zenoh.hxx"
diff --git a/tests/zenohc/shm_api.cxx b/tests/zenohc/shm_api.cxx
index d8115015..5a113036 100644
--- a/tests/zenohc/shm_api.cxx
+++ b/tests/zenohc/shm_api.cxx
@@ -12,6 +12,7 @@
 //   ZettaScale Zenoh Team, <zenoh@zettascale.tech>
 //
 
+#include <chrono>
 #include <thread>
 #include <unordered_set>