From 5fa89dfcbf4fff3ead04037174a1e454299d1f30 Mon Sep 17 00:00:00 2001 From: even Date: Thu, 28 Apr 2022 22:31:58 +0800 Subject: [PATCH] Fix missing self.inflight += 1 --- rumqttc/src/state.rs | 1 + 1 file changed, 1 insertion(+) diff --git a/rumqttc/src/state.rs b/rumqttc/src/state.rs index cc9346c1c..f0cee54d8 100644 --- a/rumqttc/src/state.rs +++ b/rumqttc/src/state.rs @@ -471,6 +471,7 @@ impl MqttState { }; self.outgoing_rel[pubrel.pkid as usize] = Some(pubrel.pkid); + self.inflight += 1; Ok(pubrel) }