Notify on QoS2 pubcomp

xiaocq2001 · Jul 3, 2024 · fb290fb · fb290fb
1 parent a63216f
commit fb290fb
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 9 deletions.
diff --git a/rumqttc/src/state.rs b/rumqttc/src/state.rs
@@ -312,10 +312,6 @@ impl MqttState {
             .remove(&pubrec.pkid)
             .ok_or(StateError::Unsolicited(pubrec.pkid))?;
 
-        // TODO: deprecated
-        // Notify user about the publish, pubrel and pubcomp will be handled in background
-        // tx.success();
-
         // NOTE: Inflight - 1 for qos2 in comp
         self.outgoing_rel.insert(pubrec.pkid, tx);
         let pubrel = PubRel { pkid: pubrec.pkid };

diff --git a/rumqttc/src/v5/state.rs b/rumqttc/src/v5/state.rs
@@ -448,11 +448,6 @@ impl MqttState {
             return Err(StateError::PubRecFail {
                 reason: pubrec.reason,
             });
-        } else {
-
-            // TODO: deprecated
-            // Notifying the PUBREC from broker, PUBREL and PUBCOMP will be in backgroud
-            // tx.success();
         }
 
         // NOTE: Inflight - 1 for qos2 in comp