Refactor code.

dotnet · Jun 27, 2021 · 306bce5 · 306bce5
1 parent 8f1d4e3
commit 306bce5
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/Source/MQTTnet/Client/MqttClient.cs b/Source/MQTTnet/Client/MqttClient.cs
@@ -72,7 +72,9 @@ public async Task<MqttClientAuthenticateResult> ConnectAsync(IMqttClientOptions
             ThrowIfDisposed();
 
             if (CompareExchangeConnectionStatus(MqttClientConnectionStatus.Connecting, MqttClientConnectionStatus.Disconnected) != MqttClientConnectionStatus.Disconnected)
+            {
                 throw new InvalidOperationException("Not allowed to connect while connect/disconnect is pending.");
+            }
 
             MqttClientAuthenticateResult authenticateResult = null;
 
@@ -734,8 +736,10 @@ async Task<MqttClientPublishResult> PublishAtMostOnce(MqttPublishPacket publishP
         async Task<MqttClientPublishResult> PublishAtLeastOnceAsync(MqttPublishPacket publishPacket, CancellationToken cancellationToken)
         {
             publishPacket.PacketIdentifier = _packetIdentifierProvider.GetNextPacketIdentifier();
-            var response = await SendAndReceiveAsync<MqttPubAckPacket>(publishPacket, cancellationToken).ConfigureAwait(false);
-            return _adapter.PacketFormatterAdapter.DataConverter.CreateClientPublishResult(response);
+
+            var pubAckPacket = await SendAndReceiveAsync<MqttPubAckPacket>(publishPacket, cancellationToken).ConfigureAwait(false);
+
+            return _adapter.PacketFormatterAdapter.DataConverter.CreateClientPublishResult(pubAckPacket);
         }
 
         async Task<MqttClientPublishResult> PublishExactlyOnceAsync(MqttPublishPacket publishPacket, CancellationToken cancellationToken)