From d30fe612646043909d55ca5f181fbb474a6364a2 Mon Sep 17 00:00:00 2001 From: JanEggers Date: Thu, 19 Jul 2018 19:15:48 +0200 Subject: [PATCH] fixed missing waits --- Source/MQTTnet/Client/MqttClient.cs | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/Source/MQTTnet/Client/MqttClient.cs b/Source/MQTTnet/Client/MqttClient.cs index 4891b1f0..0fa074c2 100644 --- a/Source/MQTTnet/Client/MqttClient.cs +++ b/Source/MQTTnet/Client/MqttClient.cs @@ -229,11 +229,8 @@ namespace MQTTnet.Client try { - if (clientWasConnected) - { - await WaitForTaskAsync(_packetReceiverTask, sender).ConfigureAwait(false); - await WaitForTaskAsync(_keepAliveMessageSenderTask, sender).ConfigureAwait(false); - } + await WaitForTaskAsync(_packetReceiverTask, sender).ConfigureAwait(false); + await WaitForTaskAsync(_keepAliveMessageSenderTask, sender).ConfigureAwait(false); if (_adapter != null) {