private final class DefaultHttp2Connection.ActiveStreams
extends java.lang.Object
DefaultHttp2Connection.Event
s that would modify the list of
active streams in order to prevent modification while iterating.Modifier and Type | Field and Description |
---|---|
private java.util.List<Http2Connection.Listener> |
listeners |
private java.util.Queue<DefaultHttp2Connection.Event> |
pendingEvents |
private int |
pendingIterations |
private java.util.Set<Http2Stream> |
streams |
Constructor and Description |
---|
ActiveStreams(java.util.List<Http2Connection.Listener> listeners) |
Modifier and Type | Method and Description |
---|---|
void |
activate(DefaultHttp2Connection.DefaultStream stream) |
(package private) void |
addToActiveStreams(DefaultHttp2Connection.DefaultStream stream) |
(package private) boolean |
allowModifications() |
void |
deactivate(DefaultHttp2Connection.DefaultStream stream,
java.util.Iterator<?> itr) |
(package private) void |
decrementPendingIterations() |
Http2Stream |
forEachActiveStream(Http2StreamVisitor visitor) |
(package private) void |
incrementPendingIterations() |
(package private) void |
removeFromActiveStreams(DefaultHttp2Connection.DefaultStream stream,
java.util.Iterator<?> itr) |
int |
size() |
private final java.util.List<Http2Connection.Listener> listeners
private final java.util.Queue<DefaultHttp2Connection.Event> pendingEvents
private final java.util.Set<Http2Stream> streams
private int pendingIterations
public ActiveStreams(java.util.List<Http2Connection.Listener> listeners)
public int size()
public void activate(DefaultHttp2Connection.DefaultStream stream)
public void deactivate(DefaultHttp2Connection.DefaultStream stream, java.util.Iterator<?> itr)
public Http2Stream forEachActiveStream(Http2StreamVisitor visitor) throws Http2Exception
Http2Exception
void addToActiveStreams(DefaultHttp2Connection.DefaultStream stream)
void removeFromActiveStreams(DefaultHttp2Connection.DefaultStream stream, java.util.Iterator<?> itr)
boolean allowModifications()
void incrementPendingIterations()
void decrementPendingIterations()