netty (fix): Fix a blocking issue after handling SSE responses (#3824)

wvlet · Feb 8, 2025 · 8575738 · 8575738
1 parent 664f46b
commit 8575738
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airframe-http-netty/src/main/scala/wvlet/airframe/http/netty/NettyRequestHandler.scala b/airframe-http-netty/src/main/scala/wvlet/airframe/http/netty/NettyRequestHandler.scala
@@ -110,7 +110,7 @@ class NettyRequestHandler(config: NettyServerConfig, dispatcher: NettyBackend.Fi
 
           if (resp.isContentTypeEventStream && resp.message.isEmpty) {
             // Read SSE stream
-            val c = RxRunner.runContinuously(resp.events) {
+            val c = RxRunner.run(resp.events) {
               case OnNext(e: ServerSentEvent) =>
                 val event = e.toContent
                 val buf   = Unpooled.copiedBuffer(event.getBytes("UTF-8"))