Code review: Code moved.

Author: fabianfett

Diff for: Sources/AsyncHTTPClient/ConnectionPool.swift

@@ -17,7 +17,6 @@ import Logging
 import NIO
 import NIOConcurrencyHelpers
 import NIOHTTP1
-import NIOHTTPCompression
 import NIOSSL
 import NIOTLS
 import NIOTransportServices
@@ -456,28 +455,12 @@ class HTTP1ConnectionProvider {
         let connectionID = HTTPConnectionPool.Connection.ID.globalGenerator.next()
         let eventLoop = preference.bestEventLoop ?? self.eventLoop
         let deadline = NIODeadline.now() + (self.configuration.timeout.connect ?? .seconds(10))
-        return self.factory.makeChannel(
+        return self.factory.makeHTTP1Channel(
             connectionID: connectionID,
             deadline: deadline,
             eventLoop: eventLoop,
             logger: logger
-        ).flatMapThrowing {
-            (channel, _) -> Channel in
-
-            // add the http1.1 channel handlers
-            let syncOperations = channel.pipeline.syncOperations
-            try syncOperations.addHTTPClientHandlers(leftOverBytesStrategy: .forwardBytes)
-
-            switch self.configuration.decompression {
-            case .disabled:
-                ()
-            case .enabled(let limit):
-                let decompressHandler = NIOHTTPResponseDecompressor(limit: limit)
-                try syncOperations.addHandler(decompressHandler)
-            }
-
-            return channel
-        }
+        )
     }
 
     /// A `Waiter` represents a request that waits for a connection when none is

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

@@ -15,6 +15,7 @@
 import Logging
 import NIO
 import NIOHTTP1
+import NIOHTTPCompression
 import NIOSOCKS
 import NIOSSL
 import NIOTLS
@@ -47,6 +48,36 @@ extension HTTPConnectionPool {
 }
 
 extension HTTPConnectionPool.ConnectionFactory {
+    func makeHTTP1Channel(
+        connectionID: HTTPConnectionPool.Connection.ID,
+        deadline: NIODeadline,
+        eventLoop: EventLoop,
+        logger: Logger
+    ) -> EventLoopFuture<Channel> {
+        self.makeChannel(
+            connectionID: connectionID,
+            deadline: deadline,
+            eventLoop: eventLoop,
+            logger: logger
+        ).flatMapThrowing {
+            (channel, _) -> Channel in
+
+            // add the http1.1 channel handlers
+            let syncOperations = channel.pipeline.syncOperations
+            try syncOperations.addHTTPClientHandlers(leftOverBytesStrategy: .forwardBytes)
+
+            switch self.clientConfiguration.decompression {
+            case .disabled:
+                ()
+            case .enabled(let limit):
+                let decompressHandler = NIOHTTPResponseDecompressor(limit: limit)
+                try syncOperations.addHandler(decompressHandler)
+            }
+
+            return channel
+        }
+    }
+
     func makeChannel(
         connectionID: HTTPConnectionPool.Connection.ID,
         deadline: NIODeadline,