From 86500025238c4f747b96fd31a7ab863beb0e6541 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Josua=20J=C3=A4ger?= Date: Fri, 21 Jun 2024 19:05:12 +0200 Subject: [PATCH] fix Managed_Client_Subscribe_Samples.Connect_Client sample: (#2023) - Result was never logged (`bool subscribed`) - `subscribed` was never set, as it was not passed as a reference but as a value. --- .../Managed_Client_Subscribe_Samples.cs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/Samples/ManagedClient/Managed_Client_Subscribe_Samples.cs b/Samples/ManagedClient/Managed_Client_Subscribe_Samples.cs index b62e3173..ff2102e0 100644 --- a/Samples/ManagedClient/Managed_Client_Subscribe_Samples.cs +++ b/Samples/ManagedClient/Managed_Client_Subscribe_Samples.cs @@ -22,7 +22,7 @@ public sealed class Managed_Client_Subscribe_Samples * - Reconnecting when connection is lost. * - Storing pending messages in an internal queue so that an enqueue is possible while the client remains not connected. */ - + var mqttFactory = new MqttFactory(); var subscribed = false; @@ -43,21 +43,21 @@ public sealed class Managed_Client_Subscribe_Samples await managedMqttClient.EnqueueAsync("Topic", "Payload"); Console.WriteLine("The managed MQTT client is connected."); - + // Wait until the queue is fully processed. SpinWait.SpinUntil(() => managedMqttClient.PendingApplicationMessagesCount == 0, 10000); - + Console.WriteLine($"Pending messages = {managedMqttClient.PendingApplicationMessagesCount}"); - managedMqttClient.SubscriptionsChangedAsync += args => SubscriptionsResultAsync(args, subscribed); + managedMqttClient.SubscriptionsChangedAsync += args => SubscriptionsResultAsync(args, ref subscribed); await managedMqttClient.SubscribeAsync("Topic").ConfigureAwait(false); SpinWait.SpinUntil(() => subscribed, 1000); - Console.WriteLine("Subscription properly done"); + Console.WriteLine($"Subscription properly done {subscribed}"); } } - private static Task SubscriptionsResultAsync(SubscriptionsChangedEventArgs arg, bool subscribed) + private static Task SubscriptionsResultAsync(SubscriptionsChangedEventArgs arg, ref bool subscribed) { foreach (var mqttClientSubscribeResult in arg.SubscribeResult) {