Fire the pipelines error caught method when NWConnection's state changes to failed

Sources/NIOTransportServices/StateManagedNWConnectionChannel.swift

@@ -272,6 +272,12 @@ extension StateManagedNWConnectionChannel {
             self.connectPromise = nil
             pendingConnect.fail(error)
         }
+
+        // Step 4 Forward the connection state failed Error
+        let channelError = error as? ChannelError
+        if channelError != .eof {
+            self.pipeline.fireErrorCaught(error)
+        }
     }
 
     public func doHalfClose0(error: Error, promise: EventLoopPromise<Void>?) {

Tests/NIOTransportServicesTests/NIOTSConnectionChannelTests.swift

@@ -865,5 +865,61 @@ class NIOTSConnectionChannelTests: XCTestCase {
             .wait()
         XCTAssertNoThrow(try connection.close().wait())
     }
+
+    func testErrorIsForwardedFromFailedConnectionState() throws {
+        final class ForwardErrorHandler: ChannelDuplexHandler {
+            typealias OutboundIn = ByteBuffer
+            typealias InboundIn = ByteBuffer
+
+            private let testCompletePromise: EventLoopPromise<Error>
+            let listenerChannel: Channel
+
+            init(testCompletePromise: EventLoopPromise<Error>, listenerChannel: Channel) {
+                self.testCompletePromise = testCompletePromise
+                self.listenerChannel = listenerChannel
+            }
+            func channelActive(context: ChannelHandlerContext) {
+                let listenerErrorPromise = self.listenerChannel.eventLoop.next().makePromise(of: Error.self)
+                listenerChannel
+                    .close()
+                    .whenSuccess { _ in
+                        context.channel.write(ByteBuffer(data: Data()))
+                            .whenFailure({ error in
+                                listenerErrorPromise.succeed(error)
+                            })
+                    }
+            }
+
+            func errorCaught(context: ChannelHandlerContext, error: Error) {
+                let error = error as? ChannelError
+                XCTAssertNotEqual(error, ChannelError.eof)
+                XCTAssertEqual(error, ChannelError.ioOnClosedChannel)
+                XCTAssertNotNil(error)
+                testCompletePromise.succeed(error!)
+            }
+        }
+
+        let listener = try NIOTSListenerBootstrap(group: self.group)
+            .childChannelInitializer { channel in
+                return channel.eventLoop.makeSucceededVoidFuture()
+            }
+            .bind(host: "127.0.0.1", port: 8080)
+            .wait()
+
+        let testCompletePromise = self.group.next().makePromise(of: Error.self)
+        let connection = try NIOTSConnectionBootstrap(group: self.group)
+            .channelInitializer { channel in
+                channel.pipeline.addHandler(
+                    ForwardErrorHandler(
+                        testCompletePromise: testCompletePromise,
+                        listenerChannel: listener
+                    )
+                )
+            }
+            .connect(host: "127.0.0.1", port: 8080)
+            .wait()
+        XCTAssertNoThrow(try connection.close().wait())
+        XCTAssertNoThrow(try testCompletePromise.futureResult.wait())
+    }
 }
 #endif