Package io.netty.handler.codec.http2
Class DefaultHttp2Connection.ActiveStreams
java.lang.Object
io.netty.handler.codec.http2.DefaultHttp2Connection.ActiveStreams
- Enclosing class:
DefaultHttp2Connection
Manages the list of currently active streams. Queues any
DefaultHttp2Connection.Event
s that would modify the list of
active streams in order to prevent modification while iterating.-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final List
<Http2Connection.Listener> private final Queue
<DefaultHttp2Connection.Event> private int
private final Set
<Http2Stream> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
(package private) void
(package private) boolean
void
deactivate
(DefaultHttp2Connection.DefaultStream stream, Iterator<?> itr) (package private) void
forEachActiveStream
(Http2StreamVisitor visitor) (package private) void
(package private) void
removeFromActiveStreams
(DefaultHttp2Connection.DefaultStream stream, Iterator<?> itr) int
size()
-
Field Details
-
listeners
-
pendingEvents
-
streams
-
pendingIterations
private int pendingIterations
-
-
Constructor Details
-
ActiveStreams
ActiveStreams(List<Http2Connection.Listener> listeners)
-
-
Method Details
-
size
public int size() -
activate
-
deactivate
-
forEachActiveStream
- Throws:
Http2Exception
-
addToActiveStreams
-
removeFromActiveStreams
-
allowModifications
boolean allowModifications() -
incrementPendingIterations
void incrementPendingIterations() -
decrementPendingIterations
void decrementPendingIterations()
-