Merge pull request #205 from LelandSindt/main

Add `timeout` value.
adafruit · Mar 4, 2024 · ff6f991 · ff6f991
2 parents 048d9c0 + c493c7b
commit ff6f991
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/examples/native_networking/minimqtt_adafruitio_native_networking.py b/examples/native_networking/minimqtt_adafruitio_native_networking.py
@@ -89,7 +89,7 @@ def message(client, topic, message):
 photocell_val = 0
 while True:
     # Poll the message queue
-    mqtt_client.loop()
+    mqtt_client.loop(timeout=1)
 
     # Send a new message
     print(f"Sending photocell value: {photocell_val}...")

diff --git a/examples/native_networking/minimqtt_pub_sub_blocking_native_networking.py b/examples/native_networking/minimqtt_pub_sub_blocking_native_networking.py
@@ -91,7 +91,7 @@ def message(client, topic, message):
 # NOTE: Network reconnection is handled within this loop
 while True:
     try:
-        mqtt_client.loop()
+        mqtt_client.loop(timeout=1)
     except (ValueError, RuntimeError) as e:
         print("Failed to get data, retrying\n", e)
         wifi.reset()

diff --git a/examples/native_networking/minimqtt_pub_sub_blocking_topic_callbacks_native_networking.py b/examples/native_networking/minimqtt_pub_sub_blocking_topic_callbacks_native_networking.py
@@ -103,7 +103,7 @@ def on_message(client, topic, message):
 # NOTE: NO code below this loop will execute
 while True:
     try:
-        client.loop()
+        client.loop(timeout=1)
     except (ValueError, RuntimeError) as e:
         print("Failed to get data, retrying\n", e)
         wifi.reset()