Package io.netty.handler.codec.http2
Class UniformStreamByteDistributor.State
- java.lang.Object
-
- io.netty.handler.codec.http2.UniformStreamByteDistributor.State
-
- Enclosing class:
- UniformStreamByteDistributor
private final class UniformStreamByteDistributor.State extends java.lang.ObjectThe remote flow control state for a single stream.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) booleanenqueued(package private) Http2Streamstream(package private) intstreamableBytes(package private) booleanwindowNegative(package private) booleanwriting
-
Constructor Summary
Constructors Constructor Description State(Http2Stream stream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidaddToQueue()(package private) voidclose()(package private) voidremoveFromQueue()(package private) voidupdateStreamableBytes(int newStreamableBytes, boolean hasFrame, int windowSize)(package private) voidwrite(int numBytes, StreamByteDistributor.Writer writer)Write any allocated bytes for the given stream and updates the streamable bytes, assuming all of the bytes will be written.
-
-
-
Field Detail
-
stream
final Http2Stream stream
-
streamableBytes
int streamableBytes
-
windowNegative
boolean windowNegative
-
enqueued
boolean enqueued
-
writing
boolean writing
-
-
Constructor Detail
-
State
State(Http2Stream stream)
-
-
Method Detail
-
updateStreamableBytes
void updateStreamableBytes(int newStreamableBytes, boolean hasFrame, int windowSize)
-
write
void write(int numBytes, StreamByteDistributor.Writer writer) throws Http2ExceptionWrite any allocated bytes for the given stream and updates the streamable bytes, assuming all of the bytes will be written.- Throws:
Http2Exception
-
addToQueue
void addToQueue()
-
removeFromQueue
void removeFromQueue()
-
close
void close()
-
-