YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-15 00:15:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix build

Browse Source
This commit is contained in:
christian
2024-05-12 11:23:03 +02:00
parent c5578a93e8
commit ae4f168066
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet.Tests/Clients/ManagedMqttClient/ManagedMqttClient_Tests.cs
+8 -6
View File
@@ -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<byte>(new byte[] { 1 }), Retain = true, QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce });