From 049e332518b5573403abd9463610c91c91d95ca8 Mon Sep 17 00:00:00 2001 From: Violeta Georgieva Date: Fri, 29 Mar 2024 15:59:01 +0200 Subject: [PATCH] Do not add IdleTimeoutHandler while processing pipelined requests (#3124) --- .../java/reactor/netty/http/server/HttpTrafficHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java b/reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java index c773b1f89..5e7fc28a1 100644 --- a/reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java +++ b/reactor-netty-http/src/main/java/reactor/netty/http/server/HttpTrafficHandler.java @@ -362,6 +362,8 @@ public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) .execute(this); } else { + IdleTimeoutHandler.addIdleTimeoutHandler(ctx.pipeline(), idleTimeout); + ctx.read(); } return; @@ -461,8 +463,6 @@ public void operationComplete(ChannelFuture future) { } } - IdleTimeoutHandler.addIdleTimeoutHandler(future.channel().pipeline(), idleTimeout); - HttpServerOperations.cleanHandlerTerminate(future.channel()); }