Merge branch 'dn-large-header-tests-http2' into dn-fix-large-header-request

Author: dnadoba

Sources/AsyncHTTPClient/ConnectionPool/HTTP1/HTTP1ClientChannelHandler.swift

@@ -62,7 +62,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
     private let eventLoop: EventLoop
     private let connectionIdLoggerMetadata: Logger.MetadataValue
 
-    var onRequestCompleted: () -> Void = {}
+    var onConnectionIdle: () -> Void = {}
     init(eventLoop: EventLoop, backgroundLogger: Logger, connectionIdLoggerMetadata: Logger.MetadataValue) {
         self.eventLoop = eventLoop
         self.backgroundLogger = backgroundLogger
@@ -285,7 +285,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
                         if shouldClose {
                             context.close(promise: nil)
                         } else {
-                            self.onRequestCompleted()
+                            self.onConnectionIdle()
                         }
 
                         oldRequest.succeedRequest(buffer)
@@ -297,7 +297,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
 
                 context.writeAndFlush(self.wrapOutboundOut(.end(nil)), promise: writePromise)
             case .informConnectionIsIdle:
-                self.onRequestCompleted()
+                self.onConnectionIdle()
                 oldRequest.succeedRequest(buffer)
             }
 
@@ -314,7 +314,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
                 oldRequest.fail(error)
 
             case .informConnectionIsIdle:
-                self.onRequestCompleted()
+                self.onConnectionIdle()
                 oldRequest.fail(error)
 
             case .failWritePromise(let writePromise):

Sources/AsyncHTTPClient/ConnectionPool/HTTP1/HTTP1Connection.swift

@@ -137,7 +137,7 @@ final class HTTP1Connection {
                 backgroundLogger: logger,
                 connectionIdLoggerMetadata: "\(self.id)"
             )
-            channelHandler.onRequestCompleted = {
+            channelHandler.onConnectionIdle = {
                 self.taskCompleted()
             }
 

Tests/AsyncHTTPClientTests/HTTPClientTestUtils.swift

@@ -348,7 +348,7 @@ internal final class HTTPBin<RequestHandler: ChannelInboundHandler> where
             switch self {
             case .http1_1, .http2(_, nil), .refuse:
                 return [
-                    HTTP2Setting(parameter: .maxConcurrentStreams, value: 100),
+                    HTTP2Setting(parameter: .maxConcurrentStreams, value: 10),
                     HTTP2Setting(parameter: .maxHeaderListSize, value: HPACKDecoder.defaultMaxHeaderListSize),
                 ]
             case .http2(_, .some(let customSettings)):