From 8d23a54f78cd6b4da830fa0f24034ec38b2d9c48 Mon Sep 17 00:00:00 2001 From: dherrada Date: Thu, 10 Jun 2021 12:04:24 -0400 Subject: [PATCH 1/2] Added ability to set loop timeout --- adafruit_io/adafruit_io.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/adafruit_io/adafruit_io.py b/adafruit_io/adafruit_io.py index e91c5d9..d33f5e5 100755 --- a/adafruit_io/adafruit_io.py +++ b/adafruit_io/adafruit_io.py @@ -218,7 +218,7 @@ 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. @@ -229,7 +229,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): From 9b177456fc19c76267efb08079c9a6f8c5706b1d Mon Sep 17 00:00:00 2001 From: dherrada Date: Thu, 10 Jun 2021 12:26:03 -0400 Subject: [PATCH 2/2] Added :param: --- adafruit_io/adafruit_io.py | 1 + 1 file changed, 1 insertion(+) diff --git a/adafruit_io/adafruit_io.py b/adafruit_io/adafruit_io.py index d33f5e5..9b51d34 100755 --- a/adafruit_io/adafruit_io.py +++ b/adafruit_io/adafruit_io.py @@ -221,6 +221,7 @@ def remove_feed_callback(self, feed_key): 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.