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.Object
The remote flow control state for a single stream.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
enqueued
(package private) Http2Stream
stream
(package private) int
streamableBytes
(package private) boolean
windowNegative
(package private) boolean
writing
-
Constructor Summary
Constructors Constructor Description State(Http2Stream stream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
addToQueue()
(package private) void
close()
(package private) void
removeFromQueue()
(package private) void
updateStreamableBytes(int newStreamableBytes, boolean hasFrame, int windowSize)
(package private) void
write(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 Http2Exception
Write 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()
-
-