kopia lustrzana https://github.com/Yakifo/amqtt
fixes #116 : adding reason message to task cancellation on lost connection
rodzic
4ddc4c7474
commit
d739217162
|
@ -533,7 +533,7 @@ class MQTTClient:
|
||||||
while self.client_tasks:
|
while self.client_tasks:
|
||||||
task = self.client_tasks.popleft()
|
task = self.client_tasks.popleft()
|
||||||
if not task.done():
|
if not task.done():
|
||||||
task.cancel()
|
task.cancel(msg="Connection closed.")
|
||||||
|
|
||||||
self.logger.debug("Monitoring broker disconnection")
|
self.logger.debug("Monitoring broker disconnection")
|
||||||
# Wait for disconnection from broker (like connection lost)
|
# Wait for disconnection from broker (like connection lost)
|
||||||
|
|
Ładowanie…
Reference in New Issue