Throw an appropriate error from the writer when the channel closed

Sources/NIOCore/AsyncChannel/AsyncChannelOutboundWriterHandler.swift

@@ -137,7 +137,7 @@ internal final class NIOAsyncChannelOutboundWriterHandler<OutboundOut: Sendable>
     @inlinable
     func handlerRemoved(context: ChannelHandlerContext) {
         self.context = nil
-        self.sink?.finish()
+        self.sink?.finish(error: ChannelError.ioOnClosedChannel)
         self.writer = nil
     }
 
@@ -150,7 +150,7 @@ internal final class NIOAsyncChannelOutboundWriterHandler<OutboundOut: Sendable>
 
     @inlinable
     func channelInactive(context: ChannelHandlerContext) {
-        self.sink?.finish()
+        self.sink?.finish(error: ChannelError.ioOnClosedChannel)
         context.fireChannelInactive()
     }
 

Tests/NIOCoreTests/AsyncChannel/AsyncChannelTests.swift

@@ -81,6 +81,24 @@ final class AsyncChannelTests: XCTestCase {
         }
     }
 
+    func testAsyncChannelThrowsWhenChannelClosed() async throws {
+        let channel = NIOAsyncTestingChannel()
+        let wrapped = try await channel.testingEventLoop.executeInContext {
+            return try NIOAsyncChannel<String, String>(wrappingChannelSynchronously: channel)
+        }
+
+        try await channel.close(mode: .all)
+
+        do {
+            try await wrapped.executeThenClose { _, outbound in
+                try await outbound.write("Test")
+            }
+            XCTFail("Expected an error to be thrown")
+        } catch {
+            XCTAssertEqual(error as? ChannelError, ChannelError.ioOnClosedChannel)
+        }
+    }
+
     func testFinishingTheWriterClosesTheWriteSideOfTheChannel() async throws {
         let channel = NIOAsyncTestingChannel()
         let closeRecorder = CloseRecorder()