Fix UnitTests

2026-10-16 01:03:01 +08:00 · 2020-07-26 20:07:52 +02:00
parent 733c587e45
commit 4f51a238b3
1 changed files with 4 additions and 0 deletions
@@ -328,6 +328,8 @@ namespace MQTTnet.Tests
                        .WithTopicFilter(i.ToString()).Build();

                    await c1.SubscribeAsync(so).ConfigureAwait(false);
+
+                    await Task.Delay(10);
                }
                
                var c2 = await testEnvironment.ConnectClientAsync();
@@ -338,6 +340,8 @@ namespace MQTTnet.Tests
                    messageBuilder.WithTopic(i.ToString());

                    await c2.PublishAsync(messageBuilder.Build()).ConfigureAwait(false);
+
+                    await Task.Delay(10);
                }

                SpinWait.SpinUntil(() => receivedMessagesCount == 500, 5000);