Update downsampling tests

eclipse-zenoh · Jan 24, 2024 · 7754b65 · 7754b65
1 parent d763f06
commit 7754b65
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/zenoh/tests/interceptors.rs b/zenoh/tests/interceptors.rs
@@ -60,12 +60,24 @@ fn downsampling() {
         .res()
         .unwrap();
 
-    let ten_millis = std::time::Duration::from_millis(10);
+    let interval = std::time::Duration::from_millis(10);
+    let mut last_send_time = std::time::Instant::now();
     for i in 0..100 {
+        let start_time = last_send_time;
         println!("message {}", i);
         publisher_r100.put(format!("message {}", i)).res().unwrap();
         publisher_r50.put(format!("message {}", i)).res().unwrap();
-        std::thread::sleep(ten_millis);
+
+        let elapsed_time = start_time.elapsed();
+
+        let sleep_duration = if elapsed_time > interval {
+            std::time::Duration::from_millis(0)
+        } else {
+            interval - elapsed_time
+        };
+        std::thread::sleep(sleep_duration);
+
+        last_send_time = std::time::Instant::now();
     }
 
     // check result count of queries