try-catch

ywangd · Oct 29, 2024 · f40c2dc · f40c2dc
1 parent 885433d
commit f40c2dc
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/...sport-netty4/src/main/java/org/elasticsearch/http/netty4/Netty4HttpRequestBodyStream.java b/...sport-netty4/src/main/java/org/elasticsearch/http/netty4/Netty4HttpRequestBodyStream.java
@@ -15,7 +15,6 @@
 import io.netty.channel.ChannelFutureListener;
 import io.netty.handler.codec.http.HttpContent;
 import io.netty.handler.codec.http.LastHttpContent;
-import io.netty.util.concurrent.Future;
 
 import org.elasticsearch.core.Releasables;
 import org.elasticsearch.http.HttpBody;
@@ -67,17 +66,16 @@ public void addTracingHandler(ChunkHandler chunkHandler) {
     public void next() {
         assert closing == false : "cannot request next chunk on closing stream";
         assert handler != null : "handler must be set before requesting next chunk";
-        final Future<?> future = channel.eventLoop().submit(() -> {
+        channel.eventLoop().submit(() -> {
             requested = true;
             if (buf == null) {
                 channel.read();
             } else {
-                send();
-            }
-        });
-        future.addListener(f -> {
-            if (f.isSuccess() == false) {
-                channel.eventLoop().submit(() -> channel.pipeline().fireExceptionCaught(f.cause()));
+                try {
+                    send();
+                } catch (Exception e) {
+                    channel.pipeline().fireExceptionCaught(e);
+                }
             }
         });
     }