io.netty.handler.codec.http2

Class DefaultHttp2Connection

java.lang.Object

io.netty.handler.codec.http2.DefaultHttp2Connection

All Implemented Interfaces:

Http2Connection

public class DefaultHttp2Connection
extends Object
implements Http2Connection

Simple implementation of Http2Connection.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.handler.codec.http2.Http2Connection

Http2Connection.Endpoint<F extends Http2FlowController>, Http2Connection.Listener

Constructor Summary

Constructors

Constructor and Description
DefaultHttp2Connection(boolean server) Creates a connection with an immediate stream removal policy.
DefaultHttp2Connection(boolean server, Http2StreamRemovalPolicy removalPolicy) Creates a new connection with the given settings.

Method Summary

Methods

Modifier and Type	Method and Description
Set<Http2Stream>	activeStreams() Gets all streams that are actively in use.
void	addListener(Http2Connection.Listener listener) Adds a listener of stream life-cycle events.
Http2Stream	connectionStream() Gets the stream object representing the connection, itself (i.e. stream zero).
Http2Stream	createLocalStream(int streamId) Creates a new stream initiated by the local endpoint
Http2Stream	createRemoteStream(int streamId) Creates a new stream initiated by the remote endpoint.
void	deactivate(Http2Stream stream) Indicates that the given stream is no longer actively in use.
boolean	goAwayReceived() Indicates whether or not a GOAWAY was received from the remote endpoint.
void	goAwayReceived(int lastKnownStream) Indicates that a GOAWAY was received from the remote endpoint and sets the last known stream.
boolean	goAwaySent() Indicates whether or not a GOAWAY was sent to the remote endpoint.
void	goAwaySent(int lastKnownStream) Indicates that a GOAWAY was sent to the remote endpoint and sets the last known stream.
boolean	isGoAway() Indicates whether or not either endpoint has received a GOAWAY.
boolean	isServer() Indicates whether or not the local endpoint for this connection is the server.
Http2Connection.Endpoint<Http2LocalFlowController>	local() Gets a view of this connection from the local Http2Connection.Endpoint.
int	numActiveStreams() Gets the number of streams that actively in use.
Http2Connection.Endpoint<Http2RemoteFlowController>	remote() Gets a view of this connection from the remote Http2Connection.Endpoint.
void	removeListener(Http2Connection.Listener listener) Removes a listener of stream life-cycle events.
Http2Stream	requireStream(int streamId) Attempts to get the stream for the given ID.
Http2Stream	stream(int streamId) Gets the stream if it exists.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultHttp2Connection

public DefaultHttp2Connection(boolean server)

Creates a connection with an immediate stream removal policy.

Parameters:

server - whether or not this end-point is the server-side of the HTTP/2 connection.

DefaultHttp2Connection

public DefaultHttp2Connection(boolean server,
                      Http2StreamRemovalPolicy removalPolicy)

Creates a new connection with the given settings.

Parameters:

server - whether or not this end-point is the server-side of the HTTP/2 connection.

removalPolicy - the policy to be used for removal of closed stream.

Method Detail

addListener

public void addListener(Http2Connection.Listener listener)

Description copied from interface: Http2Connection

Adds a listener of stream life-cycle events. Adding the same listener multiple times has no effect.

Specified by:

addListener in interface Http2Connection

removeListener

public void removeListener(Http2Connection.Listener listener)

Description copied from interface: Http2Connection

Removes a listener of stream life-cycle events.

Specified by:

removeListener in interface Http2Connection

isServer

public boolean isServer()

Description copied from interface: Http2Connection

Indicates whether or not the local endpoint for this connection is the server.

Specified by:

isServer in interface Http2Connection

connectionStream

public Http2Stream connectionStream()

Description copied from interface: Http2Connection

Gets the stream object representing the connection, itself (i.e. stream zero). This object always exists.

Specified by:

connectionStream in interface Http2Connection

requireStream

public Http2Stream requireStream(int streamId)
                          throws Http2Exception

Description copied from interface: Http2Connection

Attempts to get the stream for the given ID. If it doesn't exist, throws.

Specified by:

requireStream in interface Http2Connection

Throws:

Http2Exception

stream

public Http2Stream stream(int streamId)

Description copied from interface: Http2Connection

Gets the stream if it exists. If not, returns null.

Specified by:

stream in interface Http2Connection

numActiveStreams

public int numActiveStreams()

Description copied from interface: Http2Connection

Gets the number of streams that actively in use. It is possible for a stream to be closed but still be considered active (e.g. there is still pending data to be written).

Specified by:

numActiveStreams in interface Http2Connection

activeStreams

public Set<Http2Stream> activeStreams()

Description copied from interface: Http2Connection

Gets all streams that are actively in use. The returned collection is sorted by priority.

Specified by:

activeStreams in interface Http2Connection

deactivate

public void deactivate(Http2Stream stream)

Description copied from interface: Http2Connection

Indicates that the given stream is no longer actively in use. If this stream was active, after calling this method it will no longer appear in the list returned by Http2Connection.activeStreams() and Http2Connection.numActiveStreams() will be decremented. In addition, all listeners will be notified of this event via Http2Connection.Listener.streamInactive(Http2Stream).

Specified by:

deactivate in interface Http2Connection

local

public Http2Connection.Endpoint<Http2LocalFlowController> local()

Description copied from interface: Http2Connection

Gets a view of this connection from the local Http2Connection.Endpoint.

Specified by:

local in interface Http2Connection

remote

public Http2Connection.Endpoint<Http2RemoteFlowController> remote()

Description copied from interface: Http2Connection

Gets a view of this connection from the remote Http2Connection.Endpoint.

Specified by:

remote in interface Http2Connection

isGoAway

public boolean isGoAway()

Description copied from interface: Http2Connection

Indicates whether or not either endpoint has received a GOAWAY.

Specified by:

isGoAway in interface Http2Connection

createLocalStream

public Http2Stream createLocalStream(int streamId)
                              throws Http2Exception

Description copied from interface: Http2Connection

Creates a new stream initiated by the local endpoint

Specified by:

createLocalStream in interface Http2Connection

Throws:

Http2Exception

See Also:

Http2Connection.Endpoint.createStream(int)

createRemoteStream

public Http2Stream createRemoteStream(int streamId)
                               throws Http2Exception

Description copied from interface: Http2Connection

Creates a new stream initiated by the remote endpoint.

Specified by:

createRemoteStream in interface Http2Connection

Throws:

Http2Exception

See Also:

Http2Connection.Endpoint.createStream(int)

goAwayReceived

public boolean goAwayReceived()

Description copied from interface: Http2Connection

Indicates whether or not a GOAWAY was received from the remote endpoint.

Specified by:

goAwayReceived in interface Http2Connection

goAwayReceived

public void goAwayReceived(int lastKnownStream)

Description copied from interface: Http2Connection

Indicates that a GOAWAY was received from the remote endpoint and sets the last known stream.

Specified by:

goAwayReceived in interface Http2Connection

goAwaySent

public boolean goAwaySent()

Description copied from interface: Http2Connection

Indicates whether or not a GOAWAY was sent to the remote endpoint.

Specified by:

goAwaySent in interface Http2Connection

goAwaySent

public void goAwaySent(int lastKnownStream)

Description copied from interface: Http2Connection

Indicates that a GOAWAY was sent to the remote endpoint and sets the last known stream.

Specified by:

goAwaySent in interface Http2Connection