umqtt.simple: publish(): Reuse existing bytearray.

pull/88/head
Paul Sokolovsky 2016-08-08 01:07:59 +03:00
rodzic 1e83b27b9d
commit 9f7b60bede
1 zmienionych plików z 2 dodań i 3 usunięć

Wyświetl plik

@ -79,9 +79,8 @@ class MQTTClient:
if qos > 0:
self.pid += 1
pid = self.pid
buf = bytearray(b"\0\0")
struct.pack_into("!H", buf, 0, pid)
self.sock.write(buf)
struct.pack_into("!H", pkt, 0, pid)
self.sock.write(pkt, 2)
self.sock.write(msg)
if qos == 1:
while 1: