diff --git a/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java b/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java index 7af75a6b24..450bd9874e 100644 --- a/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java +++ b/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java @@ -241,17 +241,6 @@ public class ChunkedWriteHandler } currentWrite.failAndRecycle(t); - if (ctx.executor().inEventLoop()) { - ctx.fireExceptionCaught(t); - } else { - ctx.executor().execute(new Runnable() { - @Override - public void run() { - ctx.fireExceptionCaught(t); - } - }); - } - closeInput(chunks); break; }