Fixed a bug in stop

Author: fadushin

ports/atomvm_mqtt_client.c

@@ -616,13 +616,15 @@ static NativeHandlerResult consume_mailbox(Context *ctx)
     uint64_t ref_ticks = term_to_ref_ticks(ref);
     term req = term_get_tuple_element(msg, 2);
 
+    NativeHandlerResult result = NativeContinue;
     if (term_is_atom(req)) {
 
         int cmd = interop_atom_term_select_int(cmd_table, req, ctx->global);
         switch (cmd) {
 
             case MQTTStopCmd:
                 do_stop(ctx, pid, ref_ticks);
+                result = NativeTerminate;
                 break;
 
             case MQTTDisconnectCmd:
@@ -674,7 +676,7 @@ static NativeHandlerResult consume_mailbox(Context *ctx)
 
     mailbox_remove_message(&ctx->mailbox, &ctx->heap);
 
-    return NativeContinue;
+    return result;
 }
 
 //

src/mqtt_client.erl

@@ -768,7 +768,12 @@ do_unsubscribe(Port, Topic) ->
 
 %% @private
 do_stop(Port) ->
-    port:do_disconnect(Port),
+    case port:do_disconnect(Port) of
+        ok ->
+            ok;
+        Error ->
+            io:format("Warning: Unable to disconnect from MQTT broker due to error ~p~n", [Error])
+    end,
     Port ! stop.
 
 %% @private