Skip to content

Commit

Permalink
Missed one
Browse files Browse the repository at this point in the history
  • Loading branch information
glbrntt committed Jul 5, 2024
1 parent 2c76206 commit 76fd253
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ internal final class NIOAsyncChannelOutboundWriterHandler<OutboundOut: Sendable>
@inlinable
func handlerRemoved(context: ChannelHandlerContext) {
self.context = nil
self.sink?.finish(error: ChannelError.ioOnClosedChannel)
self.sink?.finish(error: ChannelError._ioOnClosedChannel)
self.writer = nil
}

Expand All @@ -150,7 +150,7 @@ internal final class NIOAsyncChannelOutboundWriterHandler<OutboundOut: Sendable>

@inlinable
func channelInactive(context: ChannelHandlerContext) {
self.sink?.finish(error: ChannelError.ioOnClosedChannel)
self.sink?.finish(error: ChannelError._ioOnClosedChannel)
context.fireChannelInactive()
}

Expand Down
1 change: 1 addition & 0 deletions Sources/NIOCore/Channel.swift
Original file line number Diff line number Diff line change
Expand Up @@ -377,6 +377,7 @@ extension ChannelError {
// 'any Error' is unconditionally boxed, avoid allocating per use by statically boxing them.
static let _alreadyClosed: any Error = ChannelError.alreadyClosed
static let _inputClosed: any Error = ChannelError.inputClosed
@usableFromInline
static let _ioOnClosedChannel: any Error = ChannelError.ioOnClosedChannel
static let _operationUnsupported: any Error = ChannelError.operationUnsupported
static let _outputClosed: any Error = ChannelError.outputClosed
Expand Down

0 comments on commit 76fd253

Please sign in to comment.