Skip to content

Commit f7be51f

Browse files
committed
Don't close streams when error is caught or handler is removed
1 parent e03ee12 commit f7be51f

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

Sources/NIOHTTP2/HTTP2CommonInboundStreamMultiplexer.swift

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -214,26 +214,10 @@ extension HTTP2CommonInboundStreamMultiplexer {
214214
}
215215

216216
internal func propagateErrorCaught(_ error: any Error) {
217-
for channel in self.streams.values {
218-
channel.receiveStreamClosed(nil)
219-
}
220-
221-
for channel in self._pendingStreams.values {
222-
channel.receiveStreamClosed(nil)
223-
}
224-
225217
self.streamChannelContinuation?.finish(throwing: error)
226218
}
227219

228220
internal func propagateHandlerRemoved() {
229-
for channel in self.streams.values {
230-
channel.receiveStreamClosed(nil)
231-
}
232-
233-
for channel in self._pendingStreams.values {
234-
channel.receiveStreamClosed(nil)
235-
}
236-
237221
self.streamChannelContinuation?.finish()
238222
}
239223

0 commit comments

Comments
 (0)