From 31df8247fa419b1074576ec6a0d04abb0b2b3137 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Wed, 22 Apr 2020 12:05:05 +0200 Subject: [PATCH] Try to fix CI build. --- Tests/MQTTnet.Core.Tests/Server_Tests.cs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/Tests/MQTTnet.Core.Tests/Server_Tests.cs b/Tests/MQTTnet.Core.Tests/Server_Tests.cs index f0df09fb..271ea9cf 100644 --- a/Tests/MQTTnet.Core.Tests/Server_Tests.cs +++ b/Tests/MQTTnet.Core.Tests/Server_Tests.cs @@ -365,19 +365,19 @@ namespace MQTTnet.Tests } }); - await c1.SubscribeAsync(new MqttTopicFilter { Topic = "a", QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce }); - await c2.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 }).ConfigureAwait(false); 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); - Assert.AreEqual(2000, receivedMessagesCount); + Assert.AreEqual(1000, receivedMessagesCount); } }