Browse Source

Use Task.WhenAll to handle errors in both tasks.

Previously if there was an exception in the first task that is awaited the second task would not be awaited.
release/3.x.x
Johan x Lindqvist 5 years ago
parent
commit
ba9ceed7ce
1 changed files with 4 additions and 2 deletions
  1. +4
    -2
      Source/MQTTnet/Client/MqttClient.cs

+ 4
- 2
Source/MQTTnet/Client/MqttClient.cs View File

@@ -269,8 +269,10 @@ namespace MQTTnet.Client
await _adapter.DisconnectAsync(Options.CommunicationTimeout, CancellationToken.None).ConfigureAwait(false);
}

await WaitForTaskAsync(_packetReceiverTask, sender).ConfigureAwait(false);
await WaitForTaskAsync(_keepAlivePacketsSenderTask, sender).ConfigureAwait(false);
var receiverTask = WaitForTaskAsync(_packetReceiverTask, sender);
var keepAliveTask = WaitForTaskAsync(_keepAlivePacketsSenderTask, sender);
await Task.WhenAll(receiverTask, keepAliveTask).ConfigureAwait(false);

_logger.Verbose("Disconnected from adapter.");
}


Loading…
Cancel
Save