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.ObjectManages the list of currently active streams. Queues anyDefaultHttp2Connection.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 java.util.List<Http2Connection.Listener>listenersprivate java.util.Queue<DefaultHttp2Connection.Event>pendingEventsprivate intpendingIterationsprivate 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 voidactivate(DefaultHttp2Connection.DefaultStream stream)(package private) voidaddToActiveStreams(DefaultHttp2Connection.DefaultStream stream)(package private) booleanallowModifications()voiddeactivate(DefaultHttp2Connection.DefaultStream stream, java.util.Iterator<?> itr)(package private) voiddecrementPendingIterations()Http2StreamforEachActiveStream(Http2StreamVisitor visitor)(package private) voidincrementPendingIterations()(package private) voidremoveFromActiveStreams(DefaultHttp2Connection.DefaultStream stream, java.util.Iterator<?> itr)intsize()
-
-
-
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()
-
-