@@ -4,7 +4,7 @@ using System.Threading.Tasks; | |||||
namespace MQTTnet.Client | namespace MQTTnet.Client | ||||
{ | { | ||||
public interface IMqttClient : IApplicationMessageReceiver, IApplicationMessagePublisher | |||||
public interface IMqttClient : IApplicationMessageReceiver, IApplicationMessagePublisher, IDisposable | |||||
{ | { | ||||
bool IsConnected { get; } | bool IsConnected { get; } | ||||
@@ -12,7 +12,7 @@ using MQTTnet.Protocol; | |||||
namespace MQTTnet.Client | namespace MQTTnet.Client | ||||
{ | { | ||||
public class MqttClient : IMqttClient, IDisposable | |||||
public class MqttClient : IMqttClient | |||||
{ | { | ||||
private readonly IMqttClientAdapterFactory _adapterFactory; | private readonly IMqttClientAdapterFactory _adapterFactory; | ||||
private readonly MqttPacketDispatcher _packetDispatcher; | private readonly MqttPacketDispatcher _packetDispatcher; | ||||
@@ -5,7 +5,7 @@ using MQTTnet.Client; | |||||
namespace MQTTnet.ManagedClient | namespace MQTTnet.ManagedClient | ||||
{ | { | ||||
public interface IManagedMqttClient : IApplicationMessageReceiver, IApplicationMessagePublisher | |||||
public interface IManagedMqttClient : IApplicationMessageReceiver, IApplicationMessagePublisher, IDisposable | |||||
{ | { | ||||
bool IsConnected { get; } | bool IsConnected { get; } | ||||
@@ -11,7 +11,7 @@ using MQTTnet.Protocol; | |||||
namespace MQTTnet.ManagedClient | namespace MQTTnet.ManagedClient | ||||
{ | { | ||||
public class ManagedMqttClient : IManagedMqttClient, IDisposable | |||||
public class ManagedMqttClient : IManagedMqttClient | |||||
{ | { | ||||
private readonly BlockingCollection<MqttApplicationMessage> _messageQueue = new BlockingCollection<MqttApplicationMessage>(); | private readonly BlockingCollection<MqttApplicationMessage> _messageQueue = new BlockingCollection<MqttApplicationMessage>(); | ||||
private readonly Dictionary<string, MqttQualityOfServiceLevel> _subscriptions = new Dictionary<string, MqttQualityOfServiceLevel>(); | private readonly Dictionary<string, MqttQualityOfServiceLevel> _subscriptions = new Dictionary<string, MqttQualityOfServiceLevel>(); | ||||