From ccd102a59f9609e212c1d55ba8cee603baa5a1d5 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Fri, 30 Oct 2020 00:21:08 +0100 Subject: [PATCH] Refactor code. --- Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs | 2 +- Source/MQTTnet/Server/Status/MqttClientStatus.cs | 2 +- Source/MQTTnet/Server/Status/MqttSessionStatus.cs | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs b/Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs index ad873fb1..8844a967 100644 --- a/Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs +++ b/Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs @@ -51,7 +51,7 @@ namespace MQTTnet.PacketDispatcher throw new MqttProtocolViolationException($"Received packet '{packet}' at an unexpected time."); } - public void Reset() + public void Cancel() { foreach (var awaiter in _awaiters) { diff --git a/Source/MQTTnet/Server/Status/MqttClientStatus.cs b/Source/MQTTnet/Server/Status/MqttClientStatus.cs index 7f6448f2..0f22cffb 100644 --- a/Source/MQTTnet/Server/Status/MqttClientStatus.cs +++ b/Source/MQTTnet/Server/Status/MqttClientStatus.cs @@ -4,7 +4,7 @@ using System.Threading.Tasks; namespace MQTTnet.Server.Status { - public class MqttClientStatus : IMqttClientStatus + public sealed class MqttClientStatus : IMqttClientStatus { readonly MqttClientConnection _connection; diff --git a/Source/MQTTnet/Server/Status/MqttSessionStatus.cs b/Source/MQTTnet/Server/Status/MqttSessionStatus.cs index 2dfe22fd..a523a37e 100644 --- a/Source/MQTTnet/Server/Status/MqttSessionStatus.cs +++ b/Source/MQTTnet/Server/Status/MqttSessionStatus.cs @@ -4,7 +4,7 @@ using System.Threading.Tasks; namespace MQTTnet.Server.Status { - public class MqttSessionStatus : IMqttSessionStatus + public sealed class MqttSessionStatus : IMqttSessionStatus { readonly MqttClientSession _session; readonly MqttClientSessionsManager _sessionsManager;