Stop scheduler when data is received, considering the connection active

raccoonback · raccoonback · commit 6830298be2d1 · 2025-03-19T13:29:06.000+09:00
Signed-off-by: raccoonback &lt;kosb15@naver.com&gt;
diff --git a/reactor-netty-http/src/main/java/reactor/netty/http/Http2ConnectionLiveness.java b/reactor-netty-http/src/main/java/reactor/netty/http/Http2ConnectionLiveness.java
@@ -19,6 +19,7 @@
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
+import io.netty.handler.codec.http2.Http2DataFrame;
 import io.netty.handler.codec.http2.Http2FrameCodec;
 import io.netty.handler.codec.http2.Http2FrameWriter;
 import io.netty.handler.codec.http2.Http2PingFrame;
@@ -145,6 +146,10 @@ public void receive(Object msg) {
 				lastReceivedPingTime = System.nanoTime();
 			}
 		}
+
+		if(msg instanceof Http2DataFrame) {
+			cancel();
+		}
 	}
 
 	/**

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,7 @@`
`19`	`19`	`import io.netty.channel.ChannelFuture;`
`20`	`20`	`import io.netty.channel.ChannelFutureListener;`
`21`	`21`	`import io.netty.channel.ChannelHandlerContext;`
	`22`	`+import io.netty.handler.codec.http2.Http2DataFrame;`
`22`	`23`	`import io.netty.handler.codec.http2.Http2FrameCodec;`
`23`	`24`	`import io.netty.handler.codec.http2.Http2FrameWriter;`
`24`	`25`	`import io.netty.handler.codec.http2.Http2PingFrame;`
`@@ -145,6 +146,10 @@ public void receive(Object msg) {`
`145`	`146`	`lastReceivedPingTime = System.nanoTime();`
`146`	`147`	`}`
`147`	`148`	`}`
	`149`	`+`
	`150`	`+ if(msg instanceof Http2DataFrame) {`
	`151`	`+ cancel();`
	`152`	`+ }`
`148`	`153`	`}`
`149`	`154`
`150`	`155`	`/**`