Fix UnitTests

2026-10-20 19:58:57 +08:00 · 2018-04-01 20:53:32 +02:00
parent 8f96acaec4
commit 54a0265ef9
2 changed files with 12 additions and 2 deletions
@@ -47,7 +47,17 @@ namespace MQTTnet.Core.Tests
        {
            ThrowIfPartnerIsNull();

-            return Task.Run(() => _incomingPackets.Take(), cancellationToken);
+            return Task.Run(() =>
+            {
+                try
+                {
+                    return _incomingPackets.Take(cancellationToken);
+                }
+                catch
+                {
+                    return null;
+                }
+            }, cancellationToken);
        }

        private void EnqueuePacketInternal(MqttBasePacket packet)