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

fix error when stop is called multiple

pull/113/head
Robert Resch 2022-04-08 22:08:41 +02:00 zatwierdzone przez Florian Ludwig
rodzic 1fc0cc8d3d
commit c88bd0887d
1 zmienionych plików z 2 dodań i 3 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

5
amqtt/mqtt/protocol/client_handler.py
Wyświetl plik

@ -26,11 +26,11 @@ class ClientProtocolHandler(ProtocolHandler):
self._pingresp_queue = asyncio.Queue() self._pingresp_queue = asyncio.Queue()
self._subscriptions_waiter = dict() self._subscriptions_waiter = dict()
self._unsubscriptions_waiter = dict() self._unsubscriptions_waiter = dict()
self._disconnect_waiter = None self._disconnect_waiter = futures.Future()
async def start(self): async def start(self):
await super().start() await super().start()
if self._disconnect_waiter is None: if self._disconnect_waiter.cancelled():
self._disconnect_waiter = futures.Future() self._disconnect_waiter = futures.Future()
async def stop(self): async def stop(self):
@ -41,7 +41,6 @@ class ClientProtocolHandler(ProtocolHandler):
if not self._disconnect_waiter.done(): if not self._disconnect_waiter.done():
self._disconnect_waiter.cancel() self._disconnect_waiter.cancel()
self._disconnect_waiter = None
def _build_connect_packet(self): def _build_connect_packet(self):
vh = ConnectVariableHeader() vh = ConnectVariableHeader()