From 08028ebef86e7732d0abfa1a153647e7ac961be9 Mon Sep 17 00:00:00 2001 From: Ryan Parry-Jones <6457830+pazzarpj@users.noreply.github.com> Date: Mon, 27 Feb 2023 09:42:49 +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 e5b1dbb..bb6d413 100644 --- a/amqtt/mqtt/protocol/handler.py +++ b/amqtt/mqtt/protocol/handler.py @@ -365,8 +365,7 @@ class ProtocolHandler: waiter = asyncio.Future() self._pubcomp_waiters[app_message.packet_id] = waiter try: - await waiter - app_message.pubcomp_packet = waiter.result() + app_message.pubcomp_packet = await waiter finally: self._pubcomp_waiters.pop(app_message.packet_id, None) self.session.inflight_out.pop(app_message.packet_id, None)