swiftformat

Author: fabianfett

Diff for: Sources/AsyncHTTPClient/ConnectionPool/HTTPConnectionPool+Factory.swift

@@ -54,7 +54,7 @@ extension HTTPConnectionPool.ConnectionFactory {
         logger: Logger
     ) -> EventLoopFuture<(Channel, HTTPVersion)> {
         let channelFuture: EventLoopFuture<(Channel, HTTPVersion)>
-        
+
         if self.key.scheme.isProxyable, let proxy = self.clientConfiguration.proxy {
             switch proxy.type {
             case .socks:
@@ -63,19 +63,21 @@ extension HTTPConnectionPool.ConnectionFactory {
                     connectionID: connectionID,
                     deadline: deadline,
                     eventLoop: eventLoop,
-                    logger: logger)
+                    logger: logger
+                )
             case .http:
                 channelFuture = self.makeHTTPProxyChannel(
                     proxy,
                     connectionID: connectionID,
                     deadline: deadline,
                     eventLoop: eventLoop,
-                    logger: logger)
+                    logger: logger
+                )
             }
         } else {
             channelFuture = self.makeNonProxiedChannel(deadline: deadline, eventLoop: eventLoop, logger: logger)
         }
-        
+
         // let's map `ChannelError.connectTimeout` into a `HTTPClientError.connectTimeout`
         return channelFuture.flatMapErrorThrowing { error throws -> (Channel, HTTPVersion) in
             switch error {

Diff for: Tests/AsyncHTTPClientTests/HTTPConnectionPool+FactoryTests.swift

@@ -19,7 +19,6 @@ import NIOSOCKS
 import XCTest
 
 class HTTPConnectionPool_FactoryTests: XCTestCase {
-    
     func testConnectionCreationTimesoutIfDeadlineIsInThePast() {
         let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
         defer { XCTAssertNoThrow(try group.syncShutdownGracefully()) }
@@ -48,13 +47,13 @@ class HTTPConnectionPool_FactoryTests: XCTestCase {
             connectionID: 1,
             deadline: .now() - .seconds(1),
             eventLoop: group.next(),
-            logger: .init(label: "test")).wait()
+            logger: .init(label: "test")
+        ).wait()
         ) {
             XCTAssertEqual($0 as? HTTPClientError, .connectTimeout)
         }
     }
 
-    
     func testSOCKSConnectionCreationTimesoutIfRemoteIsUnresponsive() {
         let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
         defer { XCTAssertNoThrow(try group.syncShutdownGracefully()) }
@@ -83,7 +82,8 @@ class HTTPConnectionPool_FactoryTests: XCTestCase {
             connectionID: 1,
             deadline: .now() + .seconds(1),
             eventLoop: group.next(),
-            logger: .init(label: "test")).wait()
+            logger: .init(label: "test")
+        ).wait()
         ) {
             XCTAssertEqual($0 as? HTTPClientError, .socksHandshakeTimeout)
         }
@@ -117,7 +117,8 @@ class HTTPConnectionPool_FactoryTests: XCTestCase {
             connectionID: 1,
             deadline: .now() + .seconds(1),
             eventLoop: group.next(),
-            logger: .init(label: "test")).wait()
+            logger: .init(label: "test")
+        ).wait()
         ) {
             XCTAssertEqual($0 as? HTTPClientError, .httpProxyHandshakeTimeout)
         }
@@ -151,7 +152,8 @@ class HTTPConnectionPool_FactoryTests: XCTestCase {
             connectionID: 1,
             deadline: .now() + .seconds(1),
             eventLoop: group.next(),
-            logger: .init(label: "test")).wait()
+            logger: .init(label: "test")
+        ).wait()
         ) {
             XCTAssertEqual($0 as? HTTPClientError, .tlsHandshakeTimeout)
         }