void |
DefaultHttp2RemoteFlowController.addFlowControlled(Http2Stream stream,
Http2RemoteFlowController.FlowControlled frame) |
|
void |
Http2RemoteFlowController.addFlowControlled(Http2Stream stream,
Http2RemoteFlowController.FlowControlled payload) |
Queues a payload for transmission to the remote endpoint.
|
void |
Http2ConnectionHandler.closeStream(Http2Stream stream,
Future<Void> future) |
|
void |
Http2LifecycleManager.closeStream(Http2Stream stream,
Future<Void> future) |
Closes and deactivates the given stream .
|
void |
Http2ConnectionHandler.closeStreamLocal(Http2Stream stream,
Future<Void> future) |
Closes the local side of the given stream.
|
void |
Http2LifecycleManager.closeStreamLocal(Http2Stream stream,
Future<Void> future) |
Closes the local side of the stream .
|
void |
Http2ConnectionHandler.closeStreamRemote(Http2Stream stream,
Future<Void> future) |
Closes the remote side of the given stream.
|
void |
Http2LifecycleManager.closeStreamRemote(Http2Stream stream,
Future<Void> future) |
Closes the remote side of the stream .
|
boolean |
DefaultHttp2LocalFlowController.consumeBytes(Http2Stream stream,
int numBytes) |
|
boolean |
Http2LocalFlowController.consumeBytes(Http2Stream stream,
int numBytes) |
Indicates that the application has consumed a number of bytes for the given stream and is therefore ready to
receive more data from the remote endpoint.
|
boolean |
Http2Connection.Endpoint.created(Http2Stream stream) |
Indicates whether or not this endpoint created the given stream.
|
protected void |
InboundHttp2ToHttpAdapter.fireChannelRead(ChannelHandlerContext ctx,
FullHttpMessage<?> msg,
boolean release,
Http2Stream stream) |
Set final headers and fire a channel read event
|
protected FullHttpMessage<?> |
InboundHttp2ToHttpAdapter.getMessage(Http2Stream stream) |
|
protected void |
Http2ConnectionHandler.handleServerHeaderDecodeSizeError(ChannelHandlerContext ctx,
Http2Stream stream) |
Notifies client that this server has received headers that are larger than what it is
willing to accept.
|
boolean |
DefaultHttp2RemoteFlowController.hasFlowControlled(Http2Stream stream) |
|
boolean |
Http2RemoteFlowController.hasFlowControlled(Http2Stream stream) |
|
void |
DefaultHttp2LocalFlowController.incrementWindowSize(Http2Stream stream,
int delta) |
|
void |
DefaultHttp2RemoteFlowController.incrementWindowSize(Http2Stream stream,
int delta) |
|
void |
Http2FlowController.incrementWindowSize(Http2Stream stream,
int delta) |
Increments the size of the stream's flow control window by the given delta.
|
int |
DefaultHttp2LocalFlowController.initialWindowSize(Http2Stream stream) |
|
int |
Http2LocalFlowController.initialWindowSize(Http2Stream stream) |
Get the initial flow control window size for the given stream.
|
boolean |
DefaultHttp2RemoteFlowController.isWritable(Http2Stream stream) |
|
boolean |
Http2RemoteFlowController.isWritable(Http2Stream stream) |
Determine if the stream has bytes remaining for use in the flow control window.
|
protected FullHttpMessage<?> |
InboundHttp2ToHttpAdapter.newMessage(Http2Stream stream,
Http2Headers headers,
boolean validateHttpHeaders,
BufferAllocator alloc) |
|
protected void |
InboundHttp2ToHttpAdapter.onRstStreamRead(Http2Stream stream,
FullHttpMessage<?> msg) |
Called if a RST_STREAM is received but we have some data for that stream.
|
void |
Http2Connection.Listener.onStreamActive(Http2Stream stream) |
Notifies the listener that the given stream was made active (i.e.
|
void |
Http2ConnectionAdapter.onStreamActive(Http2Stream stream) |
|
void |
Http2EventAdapter.onStreamActive(Http2Stream stream) |
|
void |
Http2Connection.Listener.onStreamAdded(Http2Stream stream) |
Notifies the listener that the given stream was added to the connection.
|
void |
Http2ConnectionAdapter.onStreamAdded(Http2Stream stream) |
|
void |
Http2EventAdapter.onStreamAdded(Http2Stream stream) |
|
void |
Http2Connection.Listener.onStreamClosed(Http2Stream stream) |
|
void |
Http2ConnectionAdapter.onStreamClosed(Http2Stream stream) |
|
void |
Http2EventAdapter.onStreamClosed(Http2Stream stream) |
|
void |
Http2Connection.Listener.onStreamHalfClosed(Http2Stream stream) |
Notifies the listener that the given stream has transitioned from OPEN to HALF CLOSED .
|
void |
Http2ConnectionAdapter.onStreamHalfClosed(Http2Stream stream) |
|
void |
Http2EventAdapter.onStreamHalfClosed(Http2Stream stream) |
|
void |
Http2Connection.Listener.onStreamRemoved(Http2Stream stream) |
Notifies the listener that the given stream has now been removed from the connection and
will no longer be returned via Http2Connection.stream(int) .
|
void |
Http2ConnectionAdapter.onStreamRemoved(Http2Stream stream) |
|
void |
Http2EventAdapter.onStreamRemoved(Http2Stream stream) |
|
void |
InboundHttp2ToHttpAdapter.onStreamRemoved(Http2Stream stream) |
|
protected FullHttpMessage<?> |
InboundHttp2ToHttpAdapter.processHeadersBegin(ChannelHandlerContext ctx,
Http2Stream stream,
Http2Headers headers,
boolean endOfStream,
boolean allowAppend,
boolean appendToTrailer) |
Provides translation between HTTP/2 and HTTP header objects while ensuring the stream
is in a valid state for additional headers.
|
protected void |
InboundHttp2ToHttpAdapter.putMessage(Http2Stream stream,
FullHttpMessage<?> message) |
Make message be the state associated with stream .
|
void |
DefaultHttp2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream,
Buffer data,
int padding,
boolean endOfStream) |
|
void |
Http2LocalFlowController.receiveFlowControlledFrame(Http2Stream stream,
Buffer data,
int padding,
boolean endOfStream) |
Receives an inbound DATA frame from the remote endpoint and applies flow control policies to it for both
the stream as well as the connection.
|
protected void |
InboundHttp2ToHttpAdapter.removeMessage(Http2Stream stream,
boolean release) |
The stream is out of scope for the HTTP message flow and will no longer be tracked
|
Http2Stream |
Http2Connection.Endpoint.reservePushStream(int streamId,
Http2Stream parent) |
Creates a push stream in the reserved state for this endpoint and notifies all listeners.
|
int |
DefaultHttp2LocalFlowController.unconsumedBytes(Http2Stream stream) |
|
int |
Http2LocalFlowController.unconsumedBytes(Http2Stream stream) |
The number of bytes for the given stream that have been received but not yet consumed by the
application.
|
boolean |
Http2StreamVisitor.visit(Http2Stream stream) |
|
int |
DefaultHttp2LocalFlowController.windowSize(Http2Stream stream) |
|
int |
DefaultHttp2RemoteFlowController.windowSize(Http2Stream stream) |
|
int |
Http2FlowController.windowSize(Http2Stream stream) |
Get the portion of the flow control window for the given stream that is currently available for sending/receiving
frames which are subject to flow control.
|
float |
DefaultHttp2LocalFlowController.windowUpdateRatio(Http2Stream stream) |
The window update ratio is used to determine when a window update must be sent.
|
void |
DefaultHttp2LocalFlowController.windowUpdateRatio(Http2Stream stream,
float ratio) |
The window update ratio is used to determine when a window update must be sent.
|
void |
Http2RemoteFlowController.Listener.writabilityChanged(Http2Stream stream) |
|
void |
StreamByteDistributor.Writer.write(Http2Stream stream,
int numBytes) |
Writes the allocated bytes for this stream.
|