diff --git a/modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyPipeline.java b/modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyPipeline.java index f56e537962..5062a06f6f 100644 --- a/modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyPipeline.java +++ b/modules/jooby-netty/src/main/java/io/jooby/internal/netty/NettyPipeline.java @@ -5,8 +5,6 @@ */ package io.jooby.internal.netty; -import static io.netty.handler.flush.FlushConsolidationHandler.DEFAULT_EXPLICIT_FLUSH_AFTER_FLUSHES; - import java.util.concurrent.ScheduledExecutorService; import java.util.function.Supplier; @@ -18,7 +16,6 @@ import io.netty.channel.socket.SocketChannel; import io.netty.handler.codec.http.*; import io.netty.handler.codec.http.multipart.HttpDataFactory; -import io.netty.handler.flush.FlushConsolidationHandler; import io.netty.handler.ssl.SslContext; public class NettyPipeline extends ChannelInitializer { @@ -71,7 +68,11 @@ public void initChannel(SocketChannel ch) { if (sslContext != null) { p.addLast("ssl", sslContext.newHandler(ch.alloc())); } - p.addLast(new FlushConsolidationHandler(DEFAULT_EXPLICIT_FLUSH_AFTER_FLUSHES, true)); + // https://github.com/jooby-project/jooby/issues/3433: + // using new FlushConsolidationHandler(DEFAULT_EXPLICIT_FLUSH_AFTER_FLUSHES, true) + // cause the bug, for now I'm going to remove flush consolidating handler... doesn't seem to + // help much + // p.addLast(new FlushConsolidationHandler(DEFAULT_EXPLICIT_FLUSH_AFTER_FLUSHES, false)); if (http2) { var settings = new Http2Settings(maxRequestSize, sslContext != null); var extension =