mirror of
https://github.com/dotnet/MQTTnet.git
synced 2026-10-20 11:45:43 +08:00
fixed missing waits
This commit is contained in:
@@ -229,11 +229,8 @@ namespace MQTTnet.Client
|
|||||||
|
|
||||||
try
|
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)
|
if (_adapter != null)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user