Merge pull request #389 from Ticsmtc/fix-missing-inflight-update

Fix missing self.inflight += 1
bytebeamio · May 19, 2022 · 18c56c1 · 18c56c1
2 parents 233110c + 5fa89df
commit 18c56c1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rumqttc/src/state.rs b/rumqttc/src/state.rs
@@ -477,6 +477,7 @@ impl MqttState {
         };
 
         self.outgoing_rel[pubrel.pkid as usize] = Some(pubrel.pkid);
+        self.inflight += 1;
         Ok(pubrel)
     }