Move read request from handlerAdded to channelRegistered (#2289)

Related to #1873
reactor · Jun 14, 2022 · 87fb283 · 87fb283
1 parent 74f46fa
commit 87fb283
Showing 1 changed file with 10 additions and 4 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
@@ -124,10 +124,6 @@ final class HttpTrafficHandler extends ChannelHandlerAdapter implements Runnable
 	public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
 		super.handlerAdded(ctx);
 		this.ctx = ctx;
-		if (HttpServerOperations.log.isDebugEnabled()) {
-			HttpServerOperations.log.debug(format(ctx.channel(), "New http connection, requesting read"));
-		}
-		ctx.read();
 	}
 
 	@Override
@@ -266,6 +262,16 @@ else if (overflow) {
 		ctx.fireChannelRead(msg);
 	}
 
+	@Override
+	public void channelRegistered(ChannelHandlerContext ctx) {
+		ctx.fireChannelRegistered();
+		// Need to move read operation from handlerAdded to channelRegistered
+		if (HttpServerOperations.log.isDebugEnabled()) {
+			HttpServerOperations.log.debug(format(ctx.channel(), "New http connection, requesting read"));
+		}
+		ctx.read();
+	}
+
 	void sendDecodingFailures(Throwable t, Object msg) {
 		persistentConnection = false;
 		HttpServerOperations.sendDecodingFailures(ctx, listener, secure, t, msg);