Skip to content

Commit cf39fbc

Browse files
committed
loop wait_for_msg until nothing returned
1 parent c35316a commit cf39fbc

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

adafruit_minimqtt/adafruit_minimqtt.py

+11-2
Original file line numberDiff line numberDiff line change
@@ -855,8 +855,17 @@ def loop(self, timeout=1):
855855
rcs = self.ping()
856856
return rcs
857857
self._sock.settimeout(timeout)
858-
rc = self._wait_for_msg()
859-
return [rc] if rc else None
858+
859+
responses = []
860+
while True:
861+
rc = self._wait_for_msg()
862+
if rc == None:
863+
break
864+
else:
865+
responses.append(rc)
866+
867+
return responses if responses else None
868+
860869

861870
def _wait_for_msg(self, timeout=0.1):
862871
"""Reads and processes network events."""

0 commit comments

Comments
 (0)