We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e5a3f10 commit ca12a3cCopy full SHA for ca12a3c
adafruit_minimqtt/adafruit_minimqtt.py
@@ -857,22 +857,20 @@ def loop(self, timeout=0):
857
858
stamp = time.monotonic()
859
self._sock.settimeout(timeout)
860
- rcs = []
+ responses = []
861
while True:
862
rc = self._wait_for_msg()
863
- if rc == None:
+ if rc is None:
864
break
865
if time.monotonic() - stamp > self._recv_timeout:
866
if self.logger is not None:
867
self.logger.debug(
868
f"Loop timed out, message queue not empty after {self._recv_timeout}s"
869
)
870
871
- else:
872
- rcs.append(rc)
873
-
874
- return rcs if rcs else None
+ responses.append(rc)
875
+ return responses if responses else None
876
877
def _wait_for_msg(self, timeout=0.1):
878
"""Reads and processes network events."""
0 commit comments