@@ -62,7 +62,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
62
62
private let eventLoop : EventLoop
63
63
private let connectionIdLoggerMetadata : Logger . MetadataValue
64
64
65
- var onRequestCompleted : ( ) -> Void = { }
65
+ var onConnectionIdle : ( ) -> Void = { }
66
66
init ( eventLoop: EventLoop , backgroundLogger: Logger , connectionIdLoggerMetadata: Logger . MetadataValue ) {
67
67
self . eventLoop = eventLoop
68
68
self . backgroundLogger = backgroundLogger
@@ -275,7 +275,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
275
275
if shouldClose {
276
276
context. close ( promise: nil )
277
277
} else {
278
- self . onRequestCompleted ( )
278
+ self . onConnectionIdle ( )
279
279
}
280
280
281
281
oldRequest. succeedRequest ( buffer)
@@ -287,7 +287,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
287
287
288
288
context. writeAndFlush ( self . wrapOutboundOut ( . end( nil ) ) , promise: writePromise)
289
289
case . informConnectionIsIdle:
290
- self . onRequestCompleted ( )
290
+ self . onConnectionIdle ( )
291
291
oldRequest. succeedRequest ( buffer)
292
292
}
293
293
@@ -304,7 +304,7 @@ final class HTTP1ClientChannelHandler: ChannelDuplexHandler {
304
304
oldRequest. fail ( error)
305
305
306
306
case . informConnectionIsIdle:
307
- self . onRequestCompleted ( )
307
+ self . onConnectionIdle ( )
308
308
oldRequest. fail ( error)
309
309
310
310
case . failWritePromise( let writePromise) :
0 commit comments