Stop scheduler when data is received, considering the connection active

Signed-off-by: raccoonback <[email protected]>

Author: raccoonback

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