From 2ced92100850c98deb24e7bc176dcf11b13c1ce2 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Thu, 26 Jul 2018 14:48:40 +0200 Subject: [PATCH] Refactoring. --- Source/MQTTnet/Server/MqttClientSession.cs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/Source/MQTTnet/Server/MqttClientSession.cs b/Source/MQTTnet/Server/MqttClientSession.cs index ffc9fbdb..fe586636 100644 --- a/Source/MQTTnet/Server/MqttClientSession.cs +++ b/Source/MQTTnet/Server/MqttClientSession.cs @@ -29,7 +29,7 @@ namespace MQTTnet.Server private MqttApplicationMessage _willMessage; private bool _wasCleanDisconnect; private IMqttChannelAdapter _adapter; - private Task _workerTask; + private Task _workerTask; private IDisposable _cleanupHandle; public MqttClientSession( @@ -89,6 +89,7 @@ namespace MQTTnet.Server //woraround for https://github.com/dotnet/corefx/issues/24430 _cleanupHandle = _cancellationTokenSource.Token.Register(() => Cleanup()); //endworkaround + _wasCleanDisconnect = false; _willMessage = connectPacket.WillMessage;