fixup

Author: lukebakken

projects/RabbitMQ.Client/Impl/ChannelBase.cs

@@ -386,20 +386,18 @@ await _rpcSemaphore.WaitAsync(k.CancellationToken)
             try
             {
                 enqueued = Enqueue(k);
-                if (enqueued)
-                {
-                    var method = new ChannelOpen();
-                    await ModelSendAsync(in method, k.CancellationToken)
-                        .ConfigureAwait(false);
 
-                    bool result = await k;
-                    Debug.Assert(result);
+                var method = new ChannelOpen();
+                await ModelSendAsync(in method, k.CancellationToken)
+                    .ConfigureAwait(false);
 
-                    if (_publisherConfirmationsEnabled)
-                    {
-                        await ConfirmSelectAsync(publisherConfirmationTrackingEnabled, cancellationToken)
-                            .ConfigureAwait(false);
-                    }
+                bool result = await k;
+                Debug.Assert(result);
+
+                if (_publisherConfirmationsEnabled)
+                {
+                    await ConfirmSelectAsync(publisherConfirmationTrackingEnabled, cancellationToken)
+                        .ConfigureAwait(false);
                 }
             }
             finally
@@ -1752,15 +1750,13 @@ private async Task ConfirmSelectAsync(bool publisherConfirmationTrackingEnablefd
                 }
 
                 enqueued = Enqueue(k);
-                if (enqueued)
-                {
-                    var method = new ConfirmSelect(false);
-                    await ModelSendAsync(in method, k.CancellationToken)
-                        .ConfigureAwait(false);
 
-                    bool result = await k;
-                    Debug.Assert(result);
-                }
+                var method = new ConfirmSelect(false);
+                await ModelSendAsync(in method, k.CancellationToken)
+                    .ConfigureAwait(false);
+
+                bool result = await k;
+                Debug.Assert(result);
 
                 return;
             }