mqtt-sub: do not treat MQTT_CODE_CONTINUE as error in non-blocking read loop

dgarske · dgarske · commit 727d9d5fd4ca · 2026-05-15T11:52:58.000-07:00
diff --git a/examples/pub-sub/mqtt-sub.c b/examples/pub-sub/mqtt-sub.c
@@ -527,6 +527,13 @@ int sub_client(MQTTCtx *mqttCtx)
                 break;
             }
         }
+    #ifdef WOLFMQTT_NONBLOCK
+        else if (rc == MQTT_CODE_CONTINUE) {
+            /* Non-blocking: no data yet, keep polling. mqtt_check_timeout()
+             * above will convert this to MQTT_CODE_ERROR_TIMEOUT after the
+             * inactivity window, which drives the keep-alive ping branch. */
+        }
+    #endif
         else if (rc != MQTT_CODE_SUCCESS) {
             /* There was an error */
             PRINTF("MQTT Message Wait: %s (%d)",

Original file line number	Diff line number	Diff line change
`@@ -527,6 +527,13 @@ int sub_client(MQTTCtx *mqttCtx)`
`527`	`527`	`break;`
`528`	`528`	`}`
`529`	`529`	`}`
	`530`	`+ #ifdef WOLFMQTT_NONBLOCK`
	`531`	`+ else if (rc == MQTT_CODE_CONTINUE) {`
	`532`	`+ /* Non-blocking: no data yet, keep polling. mqtt_check_timeout()`
	`533`	`+ * above will convert this to MQTT_CODE_ERROR_TIMEOUT after the`
	`534`	`+ * inactivity window, which drives the keep-alive ping branch. */`
	`535`	`+ }`
	`536`	`+ #endif`
`530`	`537`	`else if (rc != MQTT_CODE_SUCCESS) {`
`531`	`538`	`/* There was an error */`
`532`	`539`	`PRINTF("MQTT Message Wait: %s (%d)",`