Skip to content

Commit

Permalink
Don't close streams when error is caught or handler is removed
Browse files Browse the repository at this point in the history
  • Loading branch information
gjcairo committed Nov 15, 2024
1 parent e03ee12 commit f7be51f
Showing 1 changed file with 0 additions and 16 deletions.
16 changes: 0 additions & 16 deletions Sources/NIOHTTP2/HTTP2CommonInboundStreamMultiplexer.swift
Original file line number Diff line number Diff line change
Expand Up @@ -214,26 +214,10 @@ extension HTTP2CommonInboundStreamMultiplexer {
}

internal func propagateErrorCaught(_ error: any Error) {
for channel in self.streams.values {
channel.receiveStreamClosed(nil)
}

for channel in self._pendingStreams.values {
channel.receiveStreamClosed(nil)
}

self.streamChannelContinuation?.finish(throwing: error)
}

internal func propagateHandlerRemoved() {
for channel in self.streams.values {
channel.receiveStreamClosed(nil)
}

for channel in self._pendingStreams.values {
channel.receiveStreamClosed(nil)
}

self.streamChannelContinuation?.finish()
}

Expand Down

0 comments on commit f7be51f

Please sign in to comment.