YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-21 12:16:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

Refactoring.

Browse Source
This commit is contained in:
Christian Kratky
2018-07-26 14:48:40 +02:00
parent 1e2fee0f33
commit 2ced921008
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientSession.cs
+2 -1
View File
@@ -29,7 +29,7 @@ namespace MQTTnet.Server
private MqttApplicationMessage _willMessage; private MqttApplicationMessage _willMessage;
private bool _wasCleanDisconnect; private bool _wasCleanDisconnect;
private IMqttChannelAdapter _adapter; private IMqttChannelAdapter _adapter;
private Task<bool> _workerTask; private Task _workerTask;
private IDisposable _cleanupHandle; private IDisposable _cleanupHandle;
public MqttClientSession( public MqttClientSession(
@@ -89,6 +89,7 @@ namespace MQTTnet.Server
//woraround for https://github.com/dotnet/corefx/issues/24430 //woraround for https://github.com/dotnet/corefx/issues/24430
_cleanupHandle = _cancellationTokenSource.Token.Register(() => Cleanup()); _cleanupHandle = _cancellationTokenSource.Token.Register(() => Cleanup());
//endworkaround //endworkaround
_wasCleanDisconnect = false; _wasCleanDisconnect = false;
_willMessage = connectPacket.WillMessage; _willMessage = connectPacket.WillMessage;