refactor sse error handling to catch Throwable instead of IOException

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

core-ng/src/main/java/core/framework/internal/web/sse/ChannelImpl.java

@@ -14,7 +14,6 @@
 import org.xnio.ChannelListener;
 import org.xnio.channels.StreamSinkChannel;
 
-import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.Deque;
@@ -219,7 +218,7 @@ public void handleEvent(StreamSinkChannel channel) {
                         return;
                     }
                 }
-            } catch (IOException e) {
+            } catch (Throwable e) {
                 LOGGER.warn("failed to write sse message, error={}", e.getMessage(), e);
                 exchange.endExchange();
             } finally {

core-ng/src/main/java/core/framework/internal/web/sse/ServerSentEventHandler.java

@@ -23,7 +23,6 @@
 import org.xnio.IoUtils;
 import org.xnio.channels.StreamSinkChannel;
 
-import java.io.IOException;
 import java.time.Duration;
 import java.util.HashMap;
 import java.util.List;
@@ -70,7 +69,7 @@ public void handleRequest(HttpServerExchange exchange) {
                 sink.getWriteSetter().set(listener);
                 sink.resumeWrites();
             }
-        } catch (IOException e) {
+        } catch (Throwable e) {
             logger.warn("failed to establish sse connection, error={}", e.getMessage(), e);
             IoUtils.safeClose(exchange.getConnection());
         }