diff --git a/adafruit_io/adafruit_io.py b/adafruit_io/adafruit_io.py index e91c5d9..9b51d34 100755 --- a/adafruit_io/adafruit_io.py +++ b/adafruit_io/adafruit_io.py @@ -218,9 +218,10 @@ def remove_feed_callback(self, feed_key): validate_feed_key(feed_key) self._client.remove_topic_callback("{0}/f/{1}".format(self._user, feed_key)) - def loop(self): + def loop(self, timeout=1): """Manually process messages from Adafruit IO. Call this method to check incoming subscription messages. + :param int timeout: Socket timeout, in seconds. Example usage of polling the message queue using loop. @@ -229,7 +230,7 @@ def loop(self): while True: io.loop() """ - self._client.loop() + self._client.loop(timeout) # Subscriptions def subscribe(self, feed_key=None, group_key=None, shared_user=None):