diff --git a/zenoh/src/net/routing/interceptor/downsampling.rs b/zenoh/src/net/routing/interceptor/downsampling.rs index 8f17081129..b6a0de67c1 100644 --- a/zenoh/src/net/routing/interceptor/downsampling.rs +++ b/zenoh/src/net/routing/interceptor/downsampling.rs @@ -45,7 +45,7 @@ impl InterceptorTrait for IngressMsgDownsampler { self.latest_message_timestamp.lock().unwrap(); if timestamp - *latest_message_timestamp - > std::time::Duration::from_millis(self.conf.threshold_ms) + >= std::time::Duration::from_millis(self.conf.threshold_ms) { *latest_message_timestamp = timestamp; log::trace!("Interceptor: Passed threshold, passing.");