From 2acca01df5ee063d36739dec7b047c75ad32964c Mon Sep 17 00:00:00 2001 From: Ryan Parry-Jones <6457830+pazzarpj@users.noreply.github.com> Date: Mon, 27 Feb 2023 09:42:35 +1100 Subject: [PATCH] Update amqtt/mqtt/protocol/handler.py Co-authored-by: not-f-elsner <123899677+not-f-elsner@users.noreply.github.com> --- amqtt/mqtt/protocol/handler.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/amqtt/mqtt/protocol/handler.py b/amqtt/mqtt/protocol/handler.py index e7e0418..e5b1dbb 100644 --- a/amqtt/mqtt/protocol/handler.py +++ b/amqtt/mqtt/protocol/handler.py @@ -353,8 +353,7 @@ class ProtocolHandler: waiter = asyncio.Future() self._pubrec_waiters[app_message.packet_id] = waiter try: - await waiter - app_message.pubrec_packet = waiter.result() + app_message.pubrec_packet = await waiter finally: self._pubrec_waiters.pop(app_message.packet_id, None) self.session.inflight_out.pop(app_message.packet_id, None)