diff --git a/Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs b/Source/MQTTnet/PacketDispatcher/MqttPacketDispatcher.cs index ad873fb..8844a96 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 7f6448f..0f22cff 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 2dfe22f..a523a37 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;