Implementation of a Http2ConnectionEncoder that dispatches all method call to another Http2ConnectionEncoder, until SETTINGS_MAX_CONCURRENT_STREAMS is reached.

When this limit is hit, instead of rejecting any new streams this implementation buffers newly created streams and their corresponding frames. Once an active stream gets closed or the maximum number of concurrent streams is increased, this encoder will automatically try to empty its buffer and create as many new streams as possible.

If a GOAWAY frame is received from the remote endpoint, all buffered writes for streams with an ID less than the specified lastStreamId will immediately fail with a Http2GoAwayException.

If the channel/encoder gets closed, all new and buffered writes will immediately fail with a Http2ChannelClosedException.

This implementation makes the buffering mostly transparent and is expected to be used as a drop-in decorator of DefaultHttp2ConnectionEncoder.

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	StreamBufferingEncoder.DataFrame
private abstract static class	StreamBufferingEncoder.Frame
private static class	StreamBufferingEncoder.GoAwayDetail
private class	StreamBufferingEncoder.HeadersFrame
public static class	StreamBufferingEncoder.Http2ChannelClosedException Thrown if buffered streams are terminated due to this encoder being closed.
public static class	StreamBufferingEncoder.Http2GoAwayException Thrown by `StreamBufferingEncoder` if buffered streams are terminated due to receipt of a `GOAWAY`.
private static class	StreamBufferingEncoder.PendingStream

Field Summary

Modifier and Type	Field and Description
private boolean	closed
private StreamBufferingEncoder.GoAwayDetail	goAwayDetail
private static final InternalLogger	logger
private int	maxConcurrentStreams
private final TreeMap<Integer, StreamBufferingEncoder.PendingStream>	pendingStreams Buffer for any streams and corresponding frames that could not be created due to the maximum concurrent stream limit being hit.

Constructor Summary

Access	Constructor and Description
public	StreamBufferingEncoder(Http2ConnectionEncoder delegate)
public	StreamBufferingEncoder(Http2ConnectionEncoder delegate, int initialMaxConcurrentStreams)

Method Summary

Modifier and Type	Method and Description
private void	cancelGoAwayStreams(StreamBufferingEncoder.GoAwayDetail goAwayDetail)
private boolean	canCreateStream() Determines whether or not we're allowed to create a new stream right now.
public void	close() Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.close. Implements io.netty5.handler.codec.http2.Http2FrameWriter.close. Closes this writer and frees any allocated resources.
private boolean	isExistingStream(int streamId)
public int	numBufferedStreams() Indicates the number of streams that are currently buffered, awaiting creation.
public void	remoteSettings(Http2Settings settings) Overrides io.netty5.handler.codec.http2.DecoratingHttp2ConnectionEncoder.remoteSettings. Implements io.netty5.handler.codec.http2.Http2ConnectionEncoder.remoteSettings. Sets the settings for the remote endpoint of the HTTP/2 connection.
private void	tryCreatePendingStreams()
public Future<Void>	writeData(ChannelHandlerContext the context to use for writing. ctx, int the stream for which to send the frame. streamId, Buffer the payload of the frame. This will be released by this method. data, int additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). A 1 byte padding is encoded as just the pad length field with value 0. A 256 byte padding is encoded as the pad length field with value 255 and 255 padding bytes appended to the end of the frame. padding, boolean indicates if this is the last frame to be sent for the stream. endOfStream) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeData. Implements io.netty5.handler.codec.http2.Http2DataWriter.writeData. Writes a `DATA` frame to the remote endpoint.
public Future<Void>	writeHeaders(ChannelHandlerContext the context to use for writing. ctx, int the stream for which to send the frame. streamId, Http2Headers the headers to be sent. headers, int additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). padding, boolean indicates if this is the last frame to be sent for the stream. endStream) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders. Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders. Writes a HEADERS frame to the remote endpoint.
public Future<Void>	writeHeaders(ChannelHandlerContext the context to use for writing. ctx, int the stream for which to send the frame. streamId, Http2Headers the headers to be sent. headers, int the stream on which this stream should depend, or 0 if it should depend on the connection. streamDependency, short the weight for this stream. weight, boolean whether this stream should be the exclusive dependant of its parent. exclusive, int additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). padding, boolean indicates if this is the last frame to be sent for the stream. endOfStream) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders. Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders. Writes a HEADERS frame with priority specified to the remote endpoint.
public Future<Void>	writeRstStream(ChannelHandlerContext the context to use for writing. ctx, int the stream for which to send the frame. streamId, long the error code indicating the nature of the failure. errorCode) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeRstStream. Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeRstStream. Writes a RST_STREAM frame to the remote endpoint.

Inherited from io.netty5.handler.codec.http2.DecoratingHttp2ConnectionEncoder:: connection consumeReceivedSettings flowController frameWriter lifecycleManager pollSentSettings

Field Detail

closed	back to summary
private boolean closed

goAwayDetail	back to summary
private StreamBufferingEncoder.GoAwayDetail goAwayDetail

logger	back to summary
private static final InternalLogger logger

maxConcurrentStreams	back to summary
private int maxConcurrentStreams

pendingStreams	back to summary
private final TreeMap<Integer, StreamBufferingEncoder.PendingStream> pendingStreams Buffer for any streams and corresponding frames that could not be created due to the maximum concurrent stream limit being hit.

Constructor Detail

StreamBufferingEncoder	back to summary
public StreamBufferingEncoder(Http2ConnectionEncoder delegate)

StreamBufferingEncoder	back to summary
public StreamBufferingEncoder(Http2ConnectionEncoder delegate, int initialMaxConcurrentStreams)

Method Detail

cancelGoAwayStreams	back to summary
private void cancelGoAwayStreams(StreamBufferingEncoder.GoAwayDetail goAwayDetail)

canCreateStream	back to summary
private boolean canCreateStream() Determines whether or not we're allowed to create a new stream right now.

close	back to summary
public void close() Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.close. Implements io.netty5.handler.codec.http2.Http2FrameWriter.close. Doc from io.netty5.handler.codec.http2.Http2FrameWriter.close. Closes this writer and frees any allocated resources. Annotations @Override

back to summary

public void close()

Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.close.

Implements io.netty5.handler.codec.http2.Http2FrameWriter.close.

Doc from io.netty5.handler.codec.http2.Http2FrameWriter.close.

Closes this writer and frees any allocated resources.

Annotations

@Override

isExistingStream	back to summary
private boolean isExistingStream(int streamId)

numBufferedStreams	back to summary
public int numBufferedStreams() Indicates the number of streams that are currently buffered, awaiting creation.

remoteSettings	back to summary
public void remoteSettings(Http2Settings settings) throws Http2Exception Overrides io.netty5.handler.codec.http2.DecoratingHttp2ConnectionEncoder.remoteSettings. Implements io.netty5.handler.codec.http2.Http2ConnectionEncoder.remoteSettings. Doc from io.netty5.handler.codec.http2.Http2ConnectionEncoder.remoteSettings. Sets the settings for the remote endpoint of the HTTP/2 connection. Annotations @Override

remoteSettings

back to summary

public void remoteSettings(Http2Settings settings) throws Http2Exception

Overrides io.netty5.handler.codec.http2.DecoratingHttp2ConnectionEncoder.remoteSettings.

Implements io.netty5.handler.codec.http2.Http2ConnectionEncoder.remoteSettings.

Doc from io.netty5.handler.codec.http2.Http2ConnectionEncoder.remoteSettings.

Sets the settings for the remote endpoint of the HTTP/2 connection.

Annotations

@Override

tryCreatePendingStreams	back to summary
private void tryCreatePendingStreams()

writeData back to summary

writeData	back to summary
public Future<Void> writeData(ChannelHandlerContext ctx, int streamId, Buffer data, int padding, boolean endOfStream) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeData. Implements io.netty5.handler.codec.http2.Http2DataWriter.writeData. Doc from io.netty5.handler.codec.http2.Http2DataWriter.writeData. Writes a `DATA` frame to the remote endpoint. This will result in one or more frames being written to the context. Parameters ctx:ChannelHandlerContext the context to use for writing. streamId:int the stream for which to send the frame. data:Buffer the payload of the frame. This will be released by this method. padding:int additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). A 1 byte padding is encoded as just the pad length field with value 0. A 256 byte padding is encoded as the pad length field with value 255 and 255 padding bytes appended to the end of the frame. endOfStream:boolean indicates if this is the last frame to be sent for the stream. Returns:Future<Void> the future for the write. Annotations @Override

public Future<Void> writeData(ChannelHandlerContext ctx, int streamId, Buffer data, int padding, boolean endOfStream)

Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeData.

Implements io.netty5.handler.codec.http2.Http2DataWriter.writeData.

Doc from io.netty5.handler.codec.http2.Http2DataWriter.writeData.

Writes a DATA frame to the remote endpoint. This will result in one or more frames being written to the context.

Parameters

ctx:ChannelHandlerContext: the context to use for writing.
streamId:int: the stream for which to send the frame.
data:Buffer: the payload of the frame. This will be released by this method.
padding:int: additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). A 1 byte padding is encoded as just the pad length field with value 0. A 256 byte padding is encoded as the pad length field with value 255 and 255 padding bytes appended to the end of the frame.
endOfStream:boolean: indicates if this is the last frame to be sent for the stream.

Returns:Future<Void>

the future for the write.

Annotations

@Override

writeHeaders	back to summary
public Future<Void> writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders. Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders. Doc from io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders. Writes a HEADERS frame to the remote endpoint. Parameters ctx:ChannelHandlerContext the context to use for writing. streamId:int the stream for which to send the frame. headers:Http2Headers the headers to be sent. padding:int additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). endStream:boolean indicates if this is the last frame to be sent for the stream. Returns:Future<Void> the future for the write. Section 10.5.1 states the following: The header block MUST be processed to ensure a consistent connection state, unless the connection is closed. If this call has modified the HPACK header state you MUST throw a connection error. If this call has NOT modified the HPACK header state you are free to throw a stream error. Annotations @Override

writeHeaders

back to summary

public Future<Void> writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int padding, boolean endStream)

Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders.

Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders.

Doc from io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders.

Writes a HEADERS frame to the remote endpoint.

Parameters

ctx:ChannelHandlerContext: the context to use for writing.
streamId:int: the stream for which to send the frame.
headers:Http2Headers: the headers to be sent.
padding:int: additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).
endStream:boolean: indicates if this is the last frame to be sent for the stream.

Returns:Future<Void>

the future for the write. Section 10.5.1 states the following:

The header block MUST be processed to ensure a consistent connection state, unless the connection is closed.

If this call has modified the HPACK header state you MUST throw a connection error.

If this call has NOT modified the HPACK header state you are free to throw a stream error.

Annotations

@Override

writeHeaders	back to summary
public Future<Void> writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders. Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders. Doc from io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders. Writes a HEADERS frame with priority specified to the remote endpoint. Parameters ctx:ChannelHandlerContext the context to use for writing. streamId:int the stream for which to send the frame. headers:Http2Headers the headers to be sent. streamDependency:int the stream on which this stream should depend, or 0 if it should depend on the connection. weight:short the weight for this stream. exclusive:boolean whether this stream should be the exclusive dependant of its parent. padding:int additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive). endOfStream:boolean indicates if this is the last frame to be sent for the stream. Returns:Future<Void> the future for the write. Section 10.5.1 states the following: The header block MUST be processed to ensure a consistent connection state, unless the connection is closed. If this call has modified the HPACK header state you MUST throw a connection error. If this call has NOT modified the HPACK header state you are free to throw a stream error. Annotations @Override

writeHeaders

back to summary

public Future<Void> writeHeaders(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream)

Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeHeaders.

Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders.

Doc from io.netty5.handler.codec.http2.Http2FrameWriter.writeHeaders.

Writes a HEADERS frame with priority specified to the remote endpoint.

Parameters

ctx:ChannelHandlerContext: the context to use for writing.
streamId:int: the stream for which to send the frame.
headers:Http2Headers: the headers to be sent.
streamDependency:int: the stream on which this stream should depend, or 0 if it should depend on the connection.
weight:short: the weight for this stream.
exclusive:boolean: whether this stream should be the exclusive dependant of its parent.
padding:int: additional bytes that should be added to obscure the true content size. Must be between 0 and 256 (inclusive).
endOfStream:boolean: indicates if this is the last frame to be sent for the stream.

Returns:Future<Void>

the future for the write. Section 10.5.1 states the following:

The header block MUST be processed to ensure a consistent connection state, unless the connection is closed.

If this call has modified the HPACK header state you MUST throw a connection error.

If this call has NOT modified the HPACK header state you are free to throw a stream error.

Annotations

@Override

writeRstStream	back to summary
public Future<Void> writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode) Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeRstStream. Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeRstStream. Doc from io.netty5.handler.codec.http2.Http2FrameWriter.writeRstStream. Writes a RST_STREAM frame to the remote endpoint. Parameters ctx:ChannelHandlerContext the context to use for writing. streamId:int the stream for which to send the frame. errorCode:long the error code indicating the nature of the failure. Returns:Future<Void> the future for the write. Annotations @Override

writeRstStream

back to summary

public Future<Void> writeRstStream(ChannelHandlerContext ctx, int streamId, long errorCode)

Overrides io.netty5.handler.codec.http2.DecoratingHttp2FrameWriter.writeRstStream.

Implements io.netty5.handler.codec.http2.Http2FrameWriter.writeRstStream.

Doc from io.netty5.handler.codec.http2.Http2FrameWriter.writeRstStream.

Writes a RST_STREAM frame to the remote endpoint.

Parameters

ctx:ChannelHandlerContext: the context to use for writing.
streamId:int: the stream for which to send the frame.
errorCode:long: the error code indicating the nature of the failure.

Returns:Future<Void>

the future for the write.

Annotations

@Override

io.netty5.handler.codec.http2 back to summary

private final Class StreamBufferingEncoder.DataFrame

Class Inheritance

extends Frame

java.lang.Object
io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame
io.netty5.handler.codec.http2.StreamBufferingEncoder.DataFrame

Field Summary

Modifier and Type	Field and Description
pack-priv final Buffer	data
pack-priv final boolean	endOfStream
pack-priv final int	padding

Inherited from io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame:: promise

Constructor Summary

Access	Constructor and Description
pack-priv	DataFrame(Buffer data, int padding, boolean endOfStream, Promise<Void> promise)

Method Summary

Modifier and Type	Method and Description
pack-priv void	release(Throwable t) Overrides io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.release. Release any resources (features, buffers, ...) associated with the frame.
pack-priv void	send(ChannelHandlerContext ctx, int streamId) Implements abstract io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.send.

Field Detail

data	back to summary
pack-priv final Buffer data

endOfStream	back to summary
pack-priv final boolean endOfStream

padding	back to summary
pack-priv final int padding

Constructor Detail

DataFrame	back to summary
pack-priv DataFrame(Buffer data, int padding, boolean endOfStream, Promise<Void> promise)

Method Detail

release	back to summary
pack-priv void release(Throwable t) Overrides io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.release. Doc from io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.release. Release any resources (features, buffers, ...) associated with the frame. Annotations @Override

release

back to summary

pack-priv void release(Throwable t)

Overrides io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.release.

Doc from io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.release.

Release any resources (features, buffers, ...) associated with the frame.

Annotations

@Override

send	back to summary
pack-priv void send(ChannelHandlerContext ctx, int streamId) Implements abstract io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.send. Annotations @Override

send

back to summary

pack-priv void send(ChannelHandlerContext ctx, int streamId)

Implements abstract io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.send.

Annotations

@Override

io.netty5.handler.codec.http2 back to summary

private abstract Class StreamBufferingEncoder.Frame

Class Inheritance

extends Object

java.lang.Object
io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame

Known Direct Subclasses

io.netty5.handler.codec.http2.StreamBufferingEncoder.HeadersFrame, io.netty5.handler.codec.http2.StreamBufferingEncoder.DataFrame

Field Summary

Modifier and Type	Field and Description
pack-priv final Promise<Void>	promise

Constructor Summary

Access	Constructor and Description
pack-priv	Frame(Promise<Void> promise)

Method Summary

Modifier and Type	Method and Description
pack-priv void	release(Throwable t) Release any resources (features, buffers, ...) associated with the frame.
pack-priv abstract void	send(ChannelHandlerContext ctx, int streamId)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

promise	back to summary
pack-priv final Promise<Void> promise

Constructor Detail

Frame	back to summary
pack-priv Frame(Promise<Void> promise)

Method Detail

release	back to summary
pack-priv void release(Throwable t) Release any resources (features, buffers, ...) associated with the frame.

send	back to summary
pack-priv abstract void send(ChannelHandlerContext ctx, int streamId)

io.netty5.handler.codec.http2 back to summary

private final Class StreamBufferingEncoder.GoAwayDetail

Class Inheritance

extends Object

java.lang.Object
io.netty5.handler.codec.http2.StreamBufferingEncoder.GoAwayDetail

Field Summary

Modifier and Type	Field and Description
private final byte[]	debugData
private final long	errorCode
private final int	lastStreamId

Constructor Summary

Access	Constructor and Description
pack-priv	GoAwayDetail(int lastStreamId, long errorCode, byte[] debugData)

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

debugData	back to summary
private final byte[] debugData

errorCode	back to summary
private final long errorCode

lastStreamId	back to summary
private final int lastStreamId

Constructor Detail

GoAwayDetail	back to summary
pack-priv GoAwayDetail(int lastStreamId, long errorCode, byte[] debugData)

io.netty5.handler.codec.http2 back to summary

private final Class StreamBufferingEncoder.HeadersFrame

Class Inheritance

extends Frame

java.lang.Object
io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame
io.netty5.handler.codec.http2.StreamBufferingEncoder.HeadersFrame

Field Summary

Modifier and Type	Field and Description
pack-priv final boolean	endOfStream
pack-priv final boolean	exclusive
pack-priv final Http2Headers	headers
pack-priv final int	padding
pack-priv final int	streamDependency
pack-priv final short	weight

Inherited from io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame:: promise

Constructor Summary

Access	Constructor and Description
pack-priv	HeadersFrame(Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, Promise<Void> promise)

Method Summary

Modifier and Type	Method and Description
pack-priv void	send(ChannelHandlerContext ctx, int streamId) Implements abstract io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.send.

Inherited from io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame:: release

Field Detail

endOfStream	back to summary
pack-priv final boolean endOfStream

exclusive	back to summary
pack-priv final boolean exclusive

headers	back to summary
pack-priv final Http2Headers headers

padding	back to summary
pack-priv final int padding

streamDependency	back to summary
pack-priv final int streamDependency

weight	back to summary
pack-priv final short weight

Constructor Detail

HeadersFrame	back to summary
pack-priv HeadersFrame(Http2Headers headers, int streamDependency, short weight, boolean exclusive, int padding, boolean endOfStream, Promise<Void> promise)

Method Detail

send

back to summary

pack-priv void send(ChannelHandlerContext ctx, int streamId)

Implements abstract io.netty5.handler.codec.http2.StreamBufferingEncoder.Frame.send.

Annotations

@Override

io.netty5.handler.codec.http2 back to summary

public final Class StreamBufferingEncoder.Http2ChannelClosedException

Class Inheritance

extends Http2Exception

java.lang.Object
java.lang.Throwable
java.lang.Exception
io.netty5.handler.codec.http2.Http2Exception
io.netty5.handler.codec.http2.StreamBufferingEncoder.Http2ChannelClosedException

Thrown if buffered streams are terminated due to this encoder being closed.

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides io.netty5.handler.codec.http2.Http2Exception.serialVersionUID.

Constructor Summary

Access	Constructor and Description
public	Http2ChannelClosedException()

Method Summary

Inherited from io.netty5.handler.codec.http2.Http2Exception:: closedStreamError connectionError connectionError error headerListSizeError isStreamError newStatic shutdownHint streamError streamError streamId

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID Hides io.netty5.handler.codec.http2.Http2Exception.serialVersionUID.

Constructor Detail

Http2ChannelClosedException	back to summary
public Http2ChannelClosedException()

io.netty5.handler.codec.http2 back to summary

public final Class StreamBufferingEncoder.Http2GoAwayException

Class Inheritance

extends Http2Exception

java.lang.Object
java.lang.Throwable
java.lang.Exception
io.netty5.handler.codec.http2.Http2Exception
io.netty5.handler.codec.http2.StreamBufferingEncoder.Http2GoAwayException

Thrown by StreamBufferingEncoder if buffered streams are terminated due to receipt of a GOAWAY.

Field Summary

Modifier and Type	Field and Description
private final StreamBufferingEncoder.GoAwayDetail	goAwayDetail
private static final long	serialVersionUID Hides io.netty5.handler.codec.http2.Http2Exception.serialVersionUID.

Constructor Summary

Access	Constructor and Description
public	Http2GoAwayException(int lastStreamId, long errorCode, byte[] debugData)
pack-priv	Http2GoAwayException(StreamBufferingEncoder.GoAwayDetail goAwayDetail)

Method Summary

Modifier and Type	Method and Description
public byte[]	debugData()
public long	errorCode()
public int	lastStreamId()

Inherited from io.netty5.handler.codec.http2.Http2Exception:: closedStreamError connectionError connectionError error headerListSizeError isStreamError newStatic shutdownHint streamError streamError streamId

Field Detail

goAwayDetail	back to summary
private final StreamBufferingEncoder.GoAwayDetail goAwayDetail

serialVersionUID	back to summary
private static final long serialVersionUID Hides io.netty5.handler.codec.http2.Http2Exception.serialVersionUID.

Constructor Detail

Http2GoAwayException	back to summary
public Http2GoAwayException(int lastStreamId, long errorCode, byte[] debugData)

Http2GoAwayException	back to summary
pack-priv Http2GoAwayException(StreamBufferingEncoder.GoAwayDetail goAwayDetail)

Method Detail

debugData	back to summary
public byte[] debugData()

errorCode	back to summary
public long errorCode()

lastStreamId	back to summary
public int lastStreamId()

Modifier and Type	Field and Description
pack-priv final ChannelHandlerContext	ctx
pack-priv final Queue<StreamBufferingEncoder.Frame>	frames
pack-priv final int	streamId

public Class StreamBufferingEncoder

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class StreamBufferingEncoder.DataFrame

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private abstract Class StreamBufferingEncoder.Frame

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class StreamBufferingEncoder.GoAwayDetail

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private final Class StreamBufferingEncoder.HeadersFrame

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Class StreamBufferingEncoder.Http2ChannelClosedException

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

public final Class StreamBufferingEncoder.Http2GoAwayException

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class StreamBufferingEncoder.PendingStream

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail