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) final Http2Stream
    stream
     
    (package private) int
    streamableBytes
     
    (package private) boolean
    windowNegative
     
    (package private) boolean
    writing
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    State(Http2Stream stream)
     

  • Method Summary

    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.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • stream

      final Http2Stream stream

    • streamableBytes

      int streamableBytes

    • windowNegative

      boolean windowNegative

    • enqueued

      boolean enqueued

    • writing

      boolean writing

  • Constructor Details

  • Method Details

    • 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()