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

Try to fix CI build.

Browse Source
This commit is contained in:
Christian Kratky
2020-04-22 12:05:05 +02:00
parent 9749f790ea
commit 31df8247fa
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Tests/MQTTnet.Core.Tests/Server_Tests.cs
+5 -5
View File
@@ -365,19 +365,19 @@ namespace MQTTnet.Tests
} }
}); });
await c1.SubscribeAsync(new MqttTopicFilter { Topic = "a", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce }); await c1.SubscribeAsync(new MqttTopicFilter { Topic = "a", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce }).ConfigureAwait(false);
await c2.SubscribeAsync(new MqttTopicFilter { Topic = "a", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce }); await c2.SubscribeAsync(new MqttTopicFilter { Topic = "a", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce }).ConfigureAwait(false);
var message = new MqttApplicationMessageBuilder().WithTopic("a").WithAtLeastOnceQoS().Build(); var message = new MqttApplicationMessageBuilder().WithTopic("a").WithAtLeastOnceQoS().Build();
for (var i = 0; i < 1000; i++) for (var i = 0; i < 500; i++)
{ {
await c1.PublishAsync(message); await c1.PublishAsync(message).ConfigureAwait(false);
} }
await Task.Delay(5000); await Task.Delay(5000);
Assert.AreEqual(2000, receivedMessagesCount); Assert.AreEqual(1000, receivedMessagesCount);
} }
} }