* Formatting. I prefer .ConfigureAwait(false); to be on its own line.

Author: lukebakken

projects/RabbitMQ.Client/client/api/ConnectionFactory.cs

@@ -561,7 +561,8 @@ public async Task<IConnection> CreateConnectionAsync(IEndpointResolver endpointR
             {
                 if (AutomaticRecoveryEnabled)
                 {
-                    return await AutorecoveringConnection.CreateAsync(config, endpointResolver, cancellationToken).ConfigureAwait(false);
+                    return await AutorecoveringConnection.CreateAsync(config, endpointResolver, cancellationToken)
+                        .ConfigureAwait(false);
                 }
                 else
                 {
@@ -620,7 +621,8 @@ internal async Task<IFrameHandler> CreateFrameHandlerAsync(
             AmqpTcpEndpoint endpoint, CancellationToken cancellationToken)
         {
             cancellationToken.ThrowIfCancellationRequested();
-            SocketFrameHandler frameHandler = await SocketFrameHandler.CreateAsync(endpoint, SocketFactory, RequestedConnectionTimeout, cancellationToken).ConfigureAwait(false);
+            SocketFrameHandler frameHandler = await SocketFrameHandler.CreateAsync(endpoint, SocketFactory, RequestedConnectionTimeout, cancellationToken)
+                .ConfigureAwait(false);
             return ConfigureFrameHandler(frameHandler);
         }
 

projects/RabbitMQ.Client/client/api/TopologyRecoveryExceptionHandler.cs

@@ -33,7 +33,9 @@ public Func<IRecordedExchange, Exception, bool> ExchangeRecoveryExceptionConditi
             set
             {
                 if (_exchangeRecoveryExceptionCondition != null)
+                {
                     throw new InvalidOperationException($"Cannot modify {nameof(ExchangeRecoveryExceptionCondition)} after it has been initialized.");
+                }
 
                 _exchangeRecoveryExceptionCondition = value ?? throw new ArgumentNullException(nameof(ExchangeRecoveryExceptionCondition));
             }
@@ -50,7 +52,9 @@ public Func<IRecordedQueue, Exception, bool> QueueRecoveryExceptionCondition
             set
             {
                 if (_queueRecoveryExceptionCondition != null)
+                {
                     throw new InvalidOperationException($"Cannot modify {nameof(QueueRecoveryExceptionCondition)} after it has been initialized.");
+                }
 
                 _queueRecoveryExceptionCondition = value ?? throw new ArgumentNullException(nameof(QueueRecoveryExceptionCondition));
             }
@@ -67,7 +71,9 @@ public Func<IRecordedBinding, Exception, bool> BindingRecoveryExceptionCondition
             set
             {
                 if (_bindingRecoveryExceptionCondition != null)
+                {
                     throw new InvalidOperationException($"Cannot modify {nameof(BindingRecoveryExceptionCondition)} after it has been initialized.");
+                }
 
                 _bindingRecoveryExceptionCondition = value ?? throw new ArgumentNullException(nameof(BindingRecoveryExceptionCondition));
             }
@@ -84,7 +90,9 @@ public Func<IRecordedConsumer, Exception, bool> ConsumerRecoveryExceptionConditi
             set
             {
                 if (_consumerRecoveryExceptionCondition != null)
+                {
                     throw new InvalidOperationException($"Cannot modify {nameof(ConsumerRecoveryExceptionCondition)} after it has been initialized.");
+                }
 
                 _consumerRecoveryExceptionCondition = value ?? throw new ArgumentNullException(nameof(ConsumerRecoveryExceptionCondition));
             }

projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.cs

@@ -76,12 +76,15 @@ void onException(Exception exception, string context) =>
                 _innerConnection.OnCallbackException(CallbackExceptionEventArgs.Build(exception, context));
         }
 
-        internal static async ValueTask<AutorecoveringConnection> CreateAsync(ConnectionConfig config, IEndpointResolver endpoints, CancellationToken cancellationToken)
+        internal static async ValueTask<AutorecoveringConnection> CreateAsync(ConnectionConfig config, IEndpointResolver endpoints,
+            CancellationToken cancellationToken)
         {
-            IFrameHandler fh = await endpoints.SelectOneAsync(config.FrameHandlerFactoryAsync, cancellationToken).ConfigureAwait(false);
+            IFrameHandler fh = await endpoints.SelectOneAsync(config.FrameHandlerFactoryAsync, cancellationToken)
+                .ConfigureAwait(false);
             Connection innerConnection = new(config, fh);
             AutorecoveringConnection connection = new(config, endpoints, innerConnection);
-            await innerConnection.OpenAsync(cancellationToken).ConfigureAwait(false);
+            await innerConnection.OpenAsync(cancellationToken)
+                .ConfigureAwait(false);
             return connection;
         }
 

projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs

@@ -134,14 +134,16 @@ public TimeSpan WriteTimeout
         public static async Task<SocketFrameHandler> CreateAsync(AmqpTcpEndpoint amqpTcpEndpoint, Func<AddressFamily, ITcpClient> socketFactory,
             TimeSpan connectionTimeout, CancellationToken cancellationToken)
         {
-            ITcpClient socket = await SocketFactory.OpenAsync(amqpTcpEndpoint, socketFactory, connectionTimeout, cancellationToken).ConfigureAwait(false);
+            ITcpClient socket = await SocketFactory.OpenAsync(amqpTcpEndpoint, socketFactory, connectionTimeout, cancellationToken)
+                .ConfigureAwait(false);
             Stream stream = socket.GetStream();
 
             if (amqpTcpEndpoint.Ssl.Enabled)
             {
                 try
                 {
-                    stream = await SslHelper.TcpUpgradeAsync(stream, amqpTcpEndpoint.Ssl, cancellationToken).ConfigureAwait(false);
+                    stream = await SslHelper.TcpUpgradeAsync(stream, amqpTcpEndpoint.Ssl, cancellationToken)
+                        .ConfigureAwait(false);
                 }
                 catch
                 {