diff --git a/Source/MQTTnet/Client/MqttClient.cs b/Source/MQTTnet/Client/MqttClient.cs index 4d36ff6c..63683193 100644 --- a/Source/MQTTnet/Client/MqttClient.cs +++ b/Source/MQTTnet/Client/MqttClient.cs @@ -176,12 +176,12 @@ namespace MQTTnet.Client public void Dispose() { - _cancellationTokenSource?.Cancel (); + _cancellationTokenSource?.Cancel (); _cancellationTokenSource?.Dispose(); _cancellationTokenSource = null; _adapter?.Dispose(); - _adapter = null; + _adapter = null; } private async Task AuthenticateAsync(MqttApplicationMessage willApplicationMessage, CancellationToken cancellationToken) diff --git a/Source/MQTTnet/Server/MqttClientSession.cs b/Source/MQTTnet/Server/MqttClientSession.cs index b2bb96b3..95b15266 100644 --- a/Source/MQTTnet/Server/MqttClientSession.cs +++ b/Source/MQTTnet/Server/MqttClientSession.cs @@ -125,7 +125,7 @@ namespace MQTTnet.Server } _adapter = null; - _cancellationTokenSource?.Cancel (); + _cancellationTokenSource?.Cancel (); _cancellationTokenSource?.Dispose(); _cancellationTokenSource = null; } @@ -240,9 +240,9 @@ namespace MQTTnet.Server { _pendingPacketsQueue?.Dispose(); - _cancellationTokenSource?.Cancel (); + _cancellationTokenSource?.Cancel (); _cancellationTokenSource?.Dispose(); - _cancellationTokenSource = null; + _cancellationTokenSource = null; } private void ProcessReceivedPacket(IMqttChannelAdapter adapter, MqttBasePacket packet, CancellationToken cancellationToken)