File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
reactor-netty-http/src/main/java/reactor/netty/http/client Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 21
21
import io .netty .channel .ChannelFutureListener ;
22
22
import io .netty .channel .ChannelHandlerContext ;
23
23
import io .netty .channel .ChannelPromise ;
24
- import io .netty .handler .codec .http2 .DefaultHttp2PingFrame ;
25
24
import io .netty .handler .codec .http2 .Http2ConnectionEncoder ;
25
+ import io .netty .handler .codec .http2 .Http2PingFrame ;
26
26
import reactor .util .Logger ;
27
27
import reactor .util .Loggers ;
28
28
import reactor .util .annotation .Nullable ;
@@ -91,8 +91,8 @@ public void channelActive(ChannelHandlerContext ctx) throws Exception {
91
91
92
92
@ Override
93
93
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 ;
96
96
if (frame .ack () && frame .content () == lastSentPingData ) {
97
97
lastReceivedPingTime = System .nanoTime ();
98
98
}
You can’t perform that action at this time.
0 commit comments