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()); }