diff --git a/Source/MQTTnet/MqttClient.cs b/Source/MQTTnet/MqttClient.cs index 88a0a143..3fba420f 100644 --- a/Source/MQTTnet/MqttClient.cs +++ b/Source/MQTTnet/MqttClient.cs @@ -1049,6 +1049,12 @@ public sealed class MqttClient : Disposable, IMqttClient switch (exception) { case OperationCanceledException: + // if (cancellationToken.IsCancellationRequested) + // { + // return; + // } + + //break; return; case MqttCommunicationException: _logger.Warning(exception, "Communication error while sending/receiving keep alive packets");