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

Add to_bytes() method on Packet

pull/8/head
Nicolas Jouanin 2015-08-08 13:57:17 +02:00
rodzic a87d989553
commit 7b5145da72
1 zmienionych plików z 5 dodań i 1 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
hbmqtt/mqtt/packet.py
Wyświetl plik

@ -171,7 +171,7 @@ class MQTTPacket:
writer.write(self.to_bytes()) writer.write(self.to_bytes())
yield from writer.drain() yield from writer.drain()
def to_bytes(self): def to_bytes(self) -> bytes:
if self.variable_header: if self.variable_header:
variable_header_bytes = self.variable_header.to_bytes() variable_header_bytes = self.variable_header.to_bytes()
else: else:
@ -208,6 +208,10 @@ class MQTTPacket:
else: else:
return cls(fixed_header, variable_header, payload) return cls(fixed_header, variable_header, payload)
@property
def bytes_length(self):
return len(self.to_bytes())
def __repr__(self): def __repr__(self):
return type(self).__name__ + '(fixed={0!r}, variable={1!r}, payload={2!r})'.\ return type(self).__name__ + '(fixed={0!r}, variable={1!r}, payload={2!r})'.\
format(self.fixed_header, self.variable_header, self.payload) format(self.fixed_header, self.variable_header, self.payload)