Package io.netty.handler.codec.http2
Class DefaultHttp2Connection.ActiveStreams
- java.lang.Object
-
- io.netty.handler.codec.http2.DefaultHttp2Connection.ActiveStreams
-
- Enclosing class:
- DefaultHttp2Connection
private final class DefaultHttp2Connection.ActiveStreams extends java.lang.Object
Manages the list of currently active streams. Queues anyDefaultHttp2Connection.Event
s that would modify the list of active streams in order to prevent modification while iterating.
-
-
Field Summary
Fields Modifier and Type Field 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 Summary
Constructors Constructor Description ActiveStreams(java.util.List<Http2Connection.Listener> listeners)
-
Method Summary
All Methods Instance Methods Concrete Methods 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, 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()
-
-
-
Field Detail
-
listeners
private final java.util.List<Http2Connection.Listener> listeners
-
pendingEvents
private final java.util.Queue<DefaultHttp2Connection.Event> pendingEvents
-
streams
private final java.util.Set<Http2Stream> streams
-
pendingIterations
private int pendingIterations
-
-
Constructor Detail
-
ActiveStreams
ActiveStreams(java.util.List<Http2Connection.Listener> listeners)
-
-
Method Detail
-
size
public int size()
-
activate
public void activate(DefaultHttp2Connection.DefaultStream stream)
-
deactivate
public void deactivate(DefaultHttp2Connection.DefaultStream stream, java.util.Iterator<?> itr)
-
forEachActiveStream
public Http2Stream forEachActiveStream(Http2StreamVisitor visitor) throws Http2Exception
- Throws:
Http2Exception
-
addToActiveStreams
void addToActiveStreams(DefaultHttp2Connection.DefaultStream stream)
-
removeFromActiveStreams
void removeFromActiveStreams(DefaultHttp2Connection.DefaultStream stream, java.util.Iterator<?> itr)
-
allowModifications
boolean allowModifications()
-
incrementPendingIterations
void incrementPendingIterations()
-
decrementPendingIterations
void decrementPendingIterations()
-
-