Skip to content

Commit bcbd6e8

Browse files
committed
Change comparison type for PING frame
Signed-off-by: raccoonback <[email protected]>
1 parent 202d036 commit bcbd6e8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

reactor-netty-http/src/main/java/reactor/netty/http/client/Http2ConnectionLivenessHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@
2121
import io.netty.channel.ChannelFutureListener;
2222
import io.netty.channel.ChannelHandlerContext;
2323
import io.netty.channel.ChannelPromise;
24-
import io.netty.handler.codec.http2.DefaultHttp2PingFrame;
2524
import io.netty.handler.codec.http2.Http2ConnectionEncoder;
25+
import io.netty.handler.codec.http2.Http2PingFrame;
2626
import reactor.util.Logger;
2727
import reactor.util.Loggers;
2828
import reactor.util.annotation.Nullable;
@@ -91,8 +91,8 @@ public void channelActive(ChannelHandlerContext ctx) throws Exception {
9191

9292
@Override
9393
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
94-
if (msg instanceof DefaultHttp2PingFrame) {
95-
DefaultHttp2PingFrame frame = (DefaultHttp2PingFrame) msg;
94+
if (msg instanceof Http2PingFrame) {
95+
Http2PingFrame frame = (Http2PingFrame) msg;
9696
if (frame.ack() && frame.content() == lastSentPingData) {
9797
lastReceivedPingTime = System.nanoTime();
9898
}

0 commit comments

Comments
 (0)