kopia lustrzana https://github.com/micropython/micropython-lib
umqtt.simple: Be sure to return socket to blocking state after check_msg().
rodzic
08f7d09353
commit
4a8ef9f99c
|
@ -112,9 +112,9 @@ class MQTTClient:
|
||||||
# messages processed internally.
|
# messages processed internally.
|
||||||
def wait_msg(self):
|
def wait_msg(self):
|
||||||
res = self.sock.read(1)
|
res = self.sock.read(1)
|
||||||
|
self.sock.setblocking(True)
|
||||||
if res is None:
|
if res is None:
|
||||||
return None
|
return None
|
||||||
self.sock.setblocking(True)
|
|
||||||
if res == b"":
|
if res == b"":
|
||||||
raise OSError(-1)
|
raise OSError(-1)
|
||||||
if res == b"\xd0": # PINGRESP
|
if res == b"\xd0": # PINGRESP
|
||||||
|
|
Ładowanie…
Reference in New Issue