Package io.grpc.netty
Class NettyClientHandler.PingCountingFrameWriter
java.lang.Object
io.netty.handler.codec.http2.DecoratingHttp2FrameWriter
io.grpc.netty.NettyClientHandler.PingCountingFrameWriter
- All Implemented Interfaces:
AbstractNettyHandler.PingLimiter
,io.netty.handler.codec.http2.Http2DataWriter
,io.netty.handler.codec.http2.Http2FrameWriter
,Closeable
,AutoCloseable
- Enclosing class:
NettyClientHandler
private static class NettyClientHandler.PingCountingFrameWriter
extends io.netty.handler.codec.http2.DecoratingHttp2FrameWriter
implements AbstractNettyHandler.PingLimiter
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.netty.handler.codec.http2.Http2FrameWriter
io.netty.handler.codec.http2.Http2FrameWriter.Configuration
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionPingCountingFrameWriter
(io.netty.handler.codec.http2.Http2FrameWriter delegate) -
Method Summary
Modifier and TypeMethodDescriptionboolean
io.netty.channel.ChannelFuture
writeData
(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.buffer.ByteBuf data, int padding, boolean endStream, io.netty.channel.ChannelPromise promise) io.netty.channel.ChannelFuture
writeHeaders
(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int padding, boolean endStream, io.netty.channel.ChannelPromise promise) io.netty.channel.ChannelFuture
writeHeaders
(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, io.netty.channel.ChannelPromise promise) io.netty.channel.ChannelFuture
writePing
(io.netty.channel.ChannelHandlerContext ctx, boolean ack, long data, io.netty.channel.ChannelPromise promise) io.netty.channel.ChannelFuture
writeWindowUpdate
(io.netty.channel.ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, io.netty.channel.ChannelPromise promise) Methods inherited from class io.netty.handler.codec.http2.DecoratingHttp2FrameWriter
close, configuration, writeFrame, writeGoAway, writePriority, writePushPromise, writeRstStream, writeSettings, writeSettingsAck
-
Field Details
-
pingCount
private int pingCount
-
-
Constructor Details
-
PingCountingFrameWriter
public PingCountingFrameWriter(io.netty.handler.codec.http2.Http2FrameWriter delegate)
-
-
Method Details
-
isPingAllowed
public boolean isPingAllowed()- Specified by:
isPingAllowed
in interfaceAbstractNettyHandler.PingLimiter
-
writeHeaders
public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int padding, boolean endStream, io.netty.channel.ChannelPromise promise) - Specified by:
writeHeaders
in interfaceio.netty.handler.codec.http2.Http2FrameWriter
- Overrides:
writeHeaders
in classio.netty.handler.codec.http2.DecoratingHttp2FrameWriter
-
writeHeaders
public io.netty.channel.ChannelFuture writeHeaders(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.handler.codec.http2.Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endStream, io.netty.channel.ChannelPromise promise) - Specified by:
writeHeaders
in interfaceio.netty.handler.codec.http2.Http2FrameWriter
- Overrides:
writeHeaders
in classio.netty.handler.codec.http2.DecoratingHttp2FrameWriter
-
writeWindowUpdate
public io.netty.channel.ChannelFuture writeWindowUpdate(io.netty.channel.ChannelHandlerContext ctx, int streamId, int windowSizeIncrement, io.netty.channel.ChannelPromise promise) - Specified by:
writeWindowUpdate
in interfaceio.netty.handler.codec.http2.Http2FrameWriter
- Overrides:
writeWindowUpdate
in classio.netty.handler.codec.http2.DecoratingHttp2FrameWriter
-
writePing
public io.netty.channel.ChannelFuture writePing(io.netty.channel.ChannelHandlerContext ctx, boolean ack, long data, io.netty.channel.ChannelPromise promise) - Specified by:
writePing
in interfaceio.netty.handler.codec.http2.Http2FrameWriter
- Overrides:
writePing
in classio.netty.handler.codec.http2.DecoratingHttp2FrameWriter
-
writeData
public io.netty.channel.ChannelFuture writeData(io.netty.channel.ChannelHandlerContext ctx, int streamId, io.netty.buffer.ByteBuf data, int padding, boolean endStream, io.netty.channel.ChannelPromise promise) - Specified by:
writeData
in interfaceio.netty.handler.codec.http2.Http2DataWriter
- Overrides:
writeData
in classio.netty.handler.codec.http2.DecoratingHttp2FrameWriter
-