Update ktor-server/ktor-server-netty/jvm/src/io/ktor/server/netty/cio/NettyHttpResponsePipeline.kt

arkanovicz · coderabbitai[bot] · arkanovicz · commit ce917649eec2 · 2026-01-25T13:43:25.000+01:00
Co-authored-by: coderabbitai[bot] &lt;136622811+coderabbitai[bot]@users.noreply.github.com&gt;
diff --git a/ktor-server/ktor-server-netty/jvm/src/io/ktor/server/netty/cio/NettyHttpResponsePipeline.kt b/ktor-server/ktor-server-netty/jvm/src/io/ktor/server/netty/cio/NettyHttpResponsePipeline.kt
@@ -183,10 +183,10 @@ internal class NettyHttpResponsePipeline(
         // Track streaming responses count
         val contentType = when (responseMessage) {
             is HttpResponse -> responseMessage.headers().get(HttpHeaders.ContentType)
-            is Http2HeadersFrame -> responseMessage.headers().get(HttpHeaders.ContentType)?.toString()
+            is Http2HeadersFrame -> responseMessage.headers().get("content-type")?.toString()
             else -> null
         }
-        if (contentType?.contains("text/event-stream") == true) {
+        if (contentType?.contains("text/event-stream", ignoreCase = true) == true) {
             call.isStreamingResponse = true
             httpHandlerState.streamingResponses.incrementAndGet()
         }

Original file line number	Diff line number	Diff line change
`@@ -183,10 +183,10 @@ internal class NettyHttpResponsePipeline(`
`183`	`183`	`// Track streaming responses count`
`184`	`184`	`val contentType = when (responseMessage) {`
`185`	`185`	`is HttpResponse -> responseMessage.headers().get(HttpHeaders.ContentType)`
`186`		`- is Http2HeadersFrame -> responseMessage.headers().get(HttpHeaders.ContentType)?.toString()`
	`186`	`+ is Http2HeadersFrame -> responseMessage.headers().get("content-type")?.toString()`
`187`	`187`	`else -> null`
`188`	`188`	`}`
`189`		`- if (contentType?.contains("text/event-stream") == true) {`
	`189`	`+ if (contentType?.contains("text/event-stream", ignoreCase = true) == true) {`
`190`	`190`	`call.isStreamingResponse = true`
`191`	`191`	`httpHandlerState.streamingResponses.incrementAndGet()`
`192`	`192`	`}`