diff --git a/reactor-netty-core/src/main/java/reactor/netty/ReactorNetty.java b/reactor-netty-core/src/main/java/reactor/netty/ReactorNetty.java index 8214ce9e6c..e3ae4a4c8e 100644 --- a/reactor-netty-core/src/main/java/reactor/netty/ReactorNetty.java +++ b/reactor-netty-core/src/main/java/reactor/netty/ReactorNetty.java @@ -41,7 +41,6 @@ import io.netty5.channel.ChannelHandlerAdapter; import io.netty5.channel.ChannelHandlerContext; import io.netty5.channel.ChannelPipeline; -import io.netty5.channel.nio.NioEventLoop; import io.netty5.handler.ssl.SslHandler; import io.netty5.handler.stream.ChunkedWriteHandler; import io.netty5.handler.timeout.IdleState; @@ -413,9 +412,10 @@ static boolean mustChunkFileTransfer(Connection c, Path file) { } ChannelPipeline p = c.channel().pipeline(); return p.get(SslHandler.class) != null || - p.get(NettyPipeline.CompressionHandler) != null || - (!(c.channel().executor() instanceof NioEventLoop) && - !"file".equals(file.toUri().getScheme())); + p.get(NettyPipeline.CompressionHandler) != null; // || + // TODO + //(!(c.channel().executor() instanceof NioEventLoop) && + // !"file".equals(file.toUri().getScheme())); } static void registerForClose(boolean shouldCleanupOnClose,