From fb290fbe34f14f4de24ce3aae765a4a7314a66f2 Mon Sep 17 00:00:00 2001
From: CQ Xiao <chxiao@microsoft.com>
Date: Wed, 3 Jul 2024 11:14:50 +0800
Subject: [PATCH] Notify on QoS2 pubcomp

---
 rumqttc/src/state.rs    | 4 ----
 rumqttc/src/v5/state.rs | 5 -----
 2 files changed, 9 deletions(-)

diff --git a/rumqttc/src/state.rs b/rumqttc/src/state.rs
index b0096c98b..e870414e7 100644
--- 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
index 0d09b0a81..d11d5cd27 100644
--- 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