Merge branch 'develop' of https://github.com/chkr1011/MQTTnet into develop

2026-10-21 12:16:02 +08:00 · 2018-09-28 22:51:27 +02:00
parent 381c59d1e5 0367ad31f1
commit 699cd5fc23
2 changed files with 9 additions and 5 deletions
@@ -138,7 +138,9 @@ namespace MQTTnet.Server

                _cleanupHandle?.Dispose();
                _cleanupHandle = null;
-
+                
+                _adapter = null;
+                _cancellationTokenSource?.Cancel(false);
                _cancellationTokenSource?.Dispose();
                _cancellationTokenSource = null;
            }
@@ -290,7 +292,9 @@ namespace MQTTnet.Server
        {
            _pendingPacketsQueue?.Dispose();

+            _cancellationTokenSource?.Cancel ();
            _cancellationTokenSource?.Dispose();
+            _cancellationTokenSource = null;
        }

        private void ProcessReceivedPacket(IMqttChannelAdapter adapter, MqttBasePacket packet, CancellationToken cancellationToken)