Fix api

ktorio · Nov 8, 2024 · f7429d9 · f7429d9
1 parent 8b75131
commit f7429d9
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/ktor-server/ktor-server-plugins/ktor-server-sse/common/src/io/ktor/server/sse/Routing.kt b/ktor-server/ktor-server-plugins/ktor-server-sse/common/src/io/ktor/server/sse/Routing.kt
@@ -146,15 +146,14 @@ private fun Route.processSSEWithoutSerialization(
 ) = processSSE(serialize, handler)
 
 private fun Route.processSSEWithSerialization(
-    serialize: ((TypeInfo, Any) -> String)?,
+    serialize: ((TypeInfo, Any) -> String),
     handler: suspend ServerSSESessionWithSerialization.() -> Unit
 ) {
     val sessionHandler: suspend ServerSSESession.() -> Unit = {
-        if (this is ServerSSESessionWithSerialization) {
-            handler()
-        } else {
-            throw IllegalStateException("ServerSSESessionWithSerialization is required.")
+        check(this is ServerSSESessionWithSerialization) {
+            "Impossible state. Please report this bug: https://youtrack.jetbrains.com/newIssue?project=KTOR"
         }
+        handler()
     }
     processSSE(serialize, sessionHandler)
 }