|
@@ -149,7 +149,7 @@ namespace MQTTnet.Client |
|
|
Properties = new MqttAuthPacketProperties |
|
|
Properties = new MqttAuthPacketProperties |
|
|
{ |
|
|
{ |
|
|
// This must always be equal to the value from the CONNECT packet. So we use it here to ensure that. |
|
|
// This must always be equal to the value from the CONNECT packet. So we use it here to ensure that. |
|
|
AuthenticationMethod = Options.AuthenticationMethod, |
|
|
|
|
|
|
|
|
AuthenticationMethod = Options.AuthenticationMethod, |
|
|
AuthenticationData = data.AuthenticationData, |
|
|
AuthenticationData = data.AuthenticationData, |
|
|
ReasonString = data.ReasonString, |
|
|
ReasonString = data.ReasonString, |
|
|
UserProperties = data.UserProperties |
|
|
UserProperties = data.UserProperties |
|
@@ -567,7 +567,7 @@ namespace MQTTnet.Client |
|
|
}; |
|
|
}; |
|
|
|
|
|
|
|
|
await SendAsync(pubRecPacket, cancellationToken).ConfigureAwait(false); |
|
|
await SendAsync(pubRecPacket, cancellationToken).ConfigureAwait(false); |
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
else |
|
|
else |
|
|
{ |
|
|
{ |
|
@@ -633,11 +633,6 @@ namespace MQTTnet.Client |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
if (task.IsCanceled || task.IsCompleted || task.IsFaulted) |
|
|
|
|
|
{ |
|
|
|
|
|
return; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
try |
|
|
try |
|
|
{ |
|
|
{ |
|
|
await task.ConfigureAwait(false); |
|
|
await task.ConfigureAwait(false); |
|
|