From 35d89c1800649d4b39fba4ab802d50b4399a5775 Mon Sep 17 00:00:00 2001 From: samson0v Date: Thu, 19 Jun 2025 10:38:12 +0300 Subject: [PATCH 1/2] Fixed on_unsubscribe callback --- tb_mqtt_client/service/mqtt_manager.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tb_mqtt_client/service/mqtt_manager.py b/tb_mqtt_client/service/mqtt_manager.py index 9cdc696..16bebbb 100644 --- a/tb_mqtt_client/service/mqtt_manager.py +++ b/tb_mqtt_client/service/mqtt_manager.py @@ -337,7 +337,7 @@ def _on_subscribe_internal(self, client, mid, qos, properties): if future and not future.done(): future.set_result(mid) - def _on_unsubscribe_internal(self, client, mid): + def _on_unsubscribe_internal(self, client, mid, _): logger.trace("Received UNSUBACK by client %r for mid=%s", client, mid) future = self._pending_unsubscriptions.pop(mid, None) if future and not future.done(): From 23322cc348bcfd882a8690a04bca917b8a074fb0 Mon Sep 17 00:00:00 2001 From: samson0v Date: Thu, 19 Jun 2025 10:40:52 +0300 Subject: [PATCH 2/2] Added properies argument to on_unsubscribe callback --- tb_mqtt_client/service/mqtt_manager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tb_mqtt_client/service/mqtt_manager.py b/tb_mqtt_client/service/mqtt_manager.py index 16bebbb..af40488 100644 --- a/tb_mqtt_client/service/mqtt_manager.py +++ b/tb_mqtt_client/service/mqtt_manager.py @@ -337,8 +337,8 @@ def _on_subscribe_internal(self, client, mid, qos, properties): if future and not future.done(): future.set_result(mid) - def _on_unsubscribe_internal(self, client, mid, _): - logger.trace("Received UNSUBACK by client %r for mid=%s", client, mid) + def _on_unsubscribe_internal(self, client, mid, properties): + logger.trace("Received UNSUBACK by client %r for mid=%s with properties %s", client, mid, properties) future = self._pending_unsubscriptions.pop(mid, None) if future and not future.done(): future.set_result(mid)