Class DefaultHttp2Connection.ActiveStreams

java.lang.Object

io.netty.handler.codec.http2.DefaultHttp2Connection.ActiveStreams

Enclosing class:

DefaultHttp2Connection

private final class DefaultHttp2Connection.ActiveStreams
extends Object

Manages the list of currently active streams. Queues any DefaultHttp2Connection.Events that would modify the list of active streams in order to prevent modification while iterating.

Field Summary

Fields

Modifier and Type	Field	Description
private final List<Http2Connection.Listener>	listeners
private final Queue<DefaultHttp2Connection.Event>	pendingEvents
private int	pendingIterations
private final Set<Http2Stream>	streams

Constructor Summary

Constructors

Constructor	Description
ActiveStreams(List<Http2Connection.Listener> listeners)

Method Summary

Modifier and Type	Method	Description
void	activate(DefaultHttp2Connection.DefaultStream stream)
(package private) void	addToActiveStreams(DefaultHttp2Connection.DefaultStream stream)
(package private) boolean	allowModifications()
void	deactivate(DefaultHttp2Connection.DefaultStream stream, Iterator<?> itr)
(package private) void	decrementPendingIterations()
Http2Stream	forEachActiveStream(Http2StreamVisitor visitor)
(package private) void	incrementPendingIterations()
(package private) void	removeFromActiveStreams(DefaultHttp2Connection.DefaultStream stream, Iterator<?> itr)
int	size()

Methods inherited from class Object

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

Field Details

listeners

private final List<Http2Connection.Listener> listeners

pendingEvents

private final Queue<DefaultHttp2Connection.Event> pendingEvents

streams

private final Set<Http2Stream> streams

pendingIterations

private int pendingIterations

Constructor Details

ActiveStreams

ActiveStreams(List<Http2Connection.Listener> listeners)

Method Details

size

public int size()

activate

public void activate(DefaultHttp2Connection.DefaultStream stream)

deactivate

public void deactivate(DefaultHttp2Connection.DefaultStream stream,
 Iterator<?> itr)

forEachActiveStream

public Http2Stream forEachActiveStream(Http2StreamVisitor visitor)
                                throws Http2Exception

Throws:

Http2Exception

addToActiveStreams

void addToActiveStreams(DefaultHttp2Connection.DefaultStream stream)

removeFromActiveStreams

void removeFromActiveStreams(DefaultHttp2Connection.DefaultStream stream,
 Iterator<?> itr)

allowModifications

boolean allowModifications()

incrementPendingIterations

void incrementPendingIterations()

decrementPendingIterations

void decrementPendingIterations()