kopia lustrzana https://github.com/Yakifo/amqtt
Fix connack tostream
rodzic
f44ea4a058
commit
0bb316374b
|
@ -34,11 +34,11 @@ class ConnackVariableHeader(MQTTVariableHeader):
|
||||||
out = b''
|
out = b''
|
||||||
# Connect acknowledge flags
|
# Connect acknowledge flags
|
||||||
if self.session_parent:
|
if self.session_parent:
|
||||||
out += '\x01'
|
out += b'\x01'
|
||||||
else:
|
else:
|
||||||
out += '\x00'
|
out += b'\x00'
|
||||||
# return code
|
# return code
|
||||||
out += int_to_bytes(self.return_code)
|
out += int_to_bytes(self.return_code.value)
|
||||||
|
|
||||||
return out
|
return out
|
||||||
|
|
||||||
|
@ -62,7 +62,7 @@ class ConnackPacket(MQTTPacket):
|
||||||
self.payload = None
|
self.payload = None
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def build(cls, session_parent, return_code):
|
def build(cls, session_parent, return_code: ReturnCode):
|
||||||
v_header = ConnackVariableHeader(session_parent, return_code)
|
v_header = ConnackVariableHeader(session_parent, return_code)
|
||||||
packet = ConnackPacket(variable_header=v_header)
|
packet = ConnackPacket(variable_header=v_header)
|
||||||
return packet
|
return packet
|
||||||
|
|
Ładowanie…
Reference in New Issue