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 1bc0c6bf81..6f753c5c51 100644 --- a/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java +++ b/handler/src/main/java/io/netty/handler/stream/ChunkedWriteHandler.java @@ -299,8 +299,8 @@ public class ChunkedWriteHandler extends ChannelDuplexHandler { ctx.flush(); requiresFlush = false; } else { - ctx.write(pendingMessage, currentWrite.promise); this.currentWrite = null; + ctx.write(pendingMessage, currentWrite.promise); requiresFlush = true; }