mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Update amqtt/mqtt/protocol/handler.py 

Co-authored-by: not-f-elsner <123899677+not-f-elsner@users.noreply.github.com>
pull/153/head
Ryan Parry-Jones 2023-02-27 09:42:35 +11:00 zatwierdzone przez Florian Ludwig
rodzic d0eb64dc19
commit 2acca01df5
1 zmienionych plików z 1 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

3
amqtt/mqtt/protocol/handler.py
Wyświetl plik

@ -353,8 +353,7 @@ class ProtocolHandler:
waiter = asyncio.Future() waiter = asyncio.Future()
self._pubrec_waiters[app_message.packet_id] = waiter self._pubrec_waiters[app_message.packet_id] = waiter
try: try:
await waiter app_message.pubrec_packet = await waiter
app_message.pubrec_packet = waiter.result()
finally: finally:
self._pubrec_waiters.pop(app_message.packet_id, None) self._pubrec_waiters.pop(app_message.packet_id, None)
self.session.inflight_out.pop(app_message.packet_id, None) self.session.inflight_out.pop(app_message.packet_id, None)