Do not execute sleep when 'pub_interval' is 0

rmqtt · Jun 15, 2023 · d903050 · d903050
1 parent e367dbe
commit d903050
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/v3.rs b/src/v3.rs
@@ -357,7 +357,9 @@ impl Client {
         let qos = v3::codec::QoS::try_from(opts.qos).unwrap();
 
         loop {
-            sleep(Duration::from_millis(opts.pub_interval)).await;
+            if opts.pub_interval > 0 {
+                sleep(Duration::from_millis(opts.pub_interval)).await;
+            }
 
             let no = (rand::prelude::random::<u64>() % pub_topic_len) + no_start;
             let pub_topic = ByteString::from(