kopia lustrzana https://github.com/Yakifo/amqtt
Fix missing positional argument on 'cancel_tasks'
rodzic
90a9344068
commit
3fe4bacf02
|
@ -430,7 +430,7 @@ class MQTTClient:
|
|||
@asyncio.coroutine
|
||||
def handle_connection_close(self):
|
||||
|
||||
def cancel_tasks(self):
|
||||
def cancel_tasks():
|
||||
while self.client_tasks:
|
||||
task = self.client_tasks.popleft()
|
||||
if not task.done():
|
||||
|
@ -456,7 +456,7 @@ class MQTTClient:
|
|||
yield from self.reconnect()
|
||||
except ConnectException:
|
||||
# Cancel client pending tasks
|
||||
cancel_tasks(self)
|
||||
cancel_tasks()
|
||||
else:
|
||||
# Cancel client pending tasks
|
||||
cancel_tasks()
|
||||
|
|
|
@ -6,7 +6,6 @@ from hbmqtt.errors import HBMQTTException
|
|||
|
||||
|
||||
class PubackPacket(MQTTPacket):
|
||||
|
||||
VARIABLE_HEADER = PacketIdVariableHeader
|
||||
PAYLOAD = None
|
||||
|
||||
|
|
Ładowanie…
Reference in New Issue