io.netty.handler.codec.http2

接口 Http2RemoteFlowController

所有超级接口:

Http2FlowController

所有已知实现类:

DefaultHttp2RemoteFlowController

@UnstableApi
public interface Http2RemoteFlowController
extends Http2FlowController

A Http2FlowController for controlling the flow of outbound DATA frames to the remote endpoint.

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	Http2RemoteFlowController.FlowControlled Implementations of this interface are used to progressively write chunks of the underlying payload to the stream.
static interface	Http2RemoteFlowController.Listener Listener to the number of flow-controlled bytes written per stream.

方法概要

限定符和类型	方法和说明
void	addFlowControlled(Http2Stream stream, Http2RemoteFlowController.FlowControlled payload) Queues a payload for transmission to the remote endpoint.
ChannelHandlerContext	channelHandlerContext() Get the ChannelHandlerContext for which to apply flow control on.
void	channelWritabilityChanged() Notification that the writability of channelHandlerContext() has changed.
boolean	hasFlowControlled(Http2Stream stream) Determine if stream has any Http2RemoteFlowController.FlowControlled frames currently queued.
boolean	isWritable(Http2Stream stream) Determine if the stream has bytes remaining for use in the flow control window.
void	listener(Http2RemoteFlowController.Listener listener) Set the active listener on the flow-controller.
void	updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) Explicitly update the dependency tree.
void	writePendingBytes() Write all data pending in the flow controller up to the flow-control limits.

从接口继承的方法 io.netty.handler.codec.http2.Http2FlowController

channelHandlerContext, incrementWindowSize, initialWindowSize, initialWindowSize, windowSize

方法详细资料

channelHandlerContext

ChannelHandlerContext channelHandlerContext()

Get the ChannelHandlerContext for which to apply flow control on.

This is intended for us by Http2RemoteFlowController.FlowControlled implementations only. Use with caution.

返回:

The ChannelHandlerContext for which to apply flow control on.

addFlowControlled

void addFlowControlled(Http2Stream stream,
                       Http2RemoteFlowController.FlowControlled payload)

Queues a payload for transmission to the remote endpoint. There is no guarantee as to when the data will be written or how it will be assigned to frames. before sending.

Writes do not actually occur until writePendingBytes() is called.

参数:

stream - the subject stream. Must not be the connection stream object.

payload - payload to write subject to flow-control accounting and ordering rules.

hasFlowControlled

boolean hasFlowControlled(Http2Stream stream)

Determine if stream has any Http2RemoteFlowController.FlowControlled frames currently queued.

参数:

stream - the stream to check if it has flow controlled frames.

返回:

true if stream has any Http2RemoteFlowController.FlowControlled frames currently queued.

writePendingBytes

void writePendingBytes()
                throws Http2Exception

Write all data pending in the flow controller up to the flow-control limits.

抛出:

Http2Exception - throws if a protocol-related error occurred.

listener

void listener(Http2RemoteFlowController.Listener listener)

Set the active listener on the flow-controller.

参数:

listener - to notify when the a write occurs, can be null.

isWritable

boolean isWritable(Http2Stream stream)

Determine if the stream has bytes remaining for use in the flow control window.

Note that this method respects channel writability. The channel must be writable for this method to return true.

参数:

stream - The stream to test.

返回:

true if the stream has bytes remaining for use in the flow control window and the channel is writable, false otherwise.

channelWritabilityChanged

void channelWritabilityChanged()
                        throws Http2Exception

Notification that the writability of channelHandlerContext() has changed.

抛出:

Http2Exception - If any writes occur as a result of this call and encounter errors.

updateDependencyTree

void updateDependencyTree(int childStreamId,
                          int parentStreamId,
                          short weight,
                          boolean exclusive)

Explicitly update the dependency tree. This method is called independently of stream state changes.

参数:

childStreamId - The stream identifier associated with the child stream.

parentStreamId - The stream identifier associated with the parent stream. May be 0, to make childStreamId and immediate child of the connection.

weight - The weight which is used relative to other child streams for parentStreamId. This value must be between 1 and 256 (inclusive).

exclusive - If childStreamId should be the exclusive dependency of parentStreamId.