diff --git a/Source/MQTTnet.Tests/Clients/ManagedMqttClient/ManagedMqttClient_Tests.cs b/Source/MQTTnet.Tests/Clients/ManagedMqttClient/ManagedMqttClient_Tests.cs index 63c5829e..dd056471 100644 --- a/Source/MQTTnet.Tests/Clients/ManagedMqttClient/ManagedMqttClient_Tests.cs +++ b/Source/MQTTnet.Tests/Clients/ManagedMqttClient/ManagedMqttClient_Tests.cs @@ -598,12 +598,13 @@ namespace MQTTnet.Tests.Clients.ManagedMqttClient } receivedOnServer.Release(); } - return Task.CompletedTask; + + return CompletedTask.Instance; }; managedClient.SynchronizingSubscriptionsFailedAsync += e => { failedOnClient.Release(); - return Task.CompletedTask; + return CompletedTask.Instance; }; await managedClient.SubscribeAsync(topic); @@ -643,12 +644,13 @@ namespace MQTTnet.Tests.Clients.ManagedMqttClient { receivedOnServer.Release(); } - return Task.CompletedTask; + + return CompletedTask.Instance; }; managedClient.SynchronizingSubscriptionsFailedAsync += e => { failedOnClient.Release(); - return Task.CompletedTask; + return CompletedTask.Instance; }; await managedClient.SubscribeAsync(topic); @@ -692,9 +694,9 @@ namespace MQTTnet.Tests.Clients.ManagedMqttClient receivedOnServer.TrySetResult(null); } } - return Task.CompletedTask; - }; + return CompletedTask.Instance; + }; await managedClient.EnqueueAsync(new MqttApplicationMessage { Topic = topic, PayloadSegment = new ArraySegment(new byte[] { 1 }), Retain = true, QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce });