Packages

c

org.http4s.blaze.http.http2

StreamFlowWindow

abstract class StreamFlowWindow extends AnyRef

Representation of the flow control state of a stream belonging to a session

The StreamFlowWindow provides the tools for tracking the flow window for both the individual stream and the session that it belongs to.

Annotations
@deprecated
Deprecated

(Since version 0.23.18) HTTP/2 support is unmaintained and will be removed in a future version.

Source
StreamFlowWindow.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamFlowWindow
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new StreamFlowWindow()

Abstract Value Members

  1. abstract def inboundConsumed(count: Int): Unit

    Signal that count bytes have been consumed by the stream

    Signal that count bytes have been consumed by the stream

    Note

    The consumed bytes are also counted for the session flow window.

  2. abstract def inboundObserved(count: Int): Boolean

    Attempts to withdraw count bytes from the inbound window of both the stream and the session.

    Attempts to withdraw count bytes from the inbound window of both the stream and the session.

    If there are sufficient bytes in the stream and session flow windows, they are subtracted, otherwise the window is unmodified.

    returns

    true if withdraw was successful, false otherwise.

  3. abstract def outboundRequest(request: Int): Int

    Request to withdraw bytes from the outbound window of the stream and the session.

    Request to withdraw bytes from the outbound window of the stream and the session.

    request

    maximum bytes to withdraw

    returns

    actual bytes withdrawn from the window

  4. abstract def remoteSettingsInitialWindowChange(delta: Int): Option[Http2Exception]

    Adjust the stream flow window to account for a change in INITIAL_WINDOW_SIZE

    Adjust the stream flow window to account for a change in INITIAL_WINDOW_SIZE

    If an error is returned, the internal state _must not_ be modified.

    delta

    change in intial window size. Maybe be positive or negative, but must not cause the window to overflow Int.MaxValue.

  5. abstract def sessionFlowControl: SessionFlowControl

    The flow control manager of the session this stream belongs to

  6. abstract def streamId: Int

    Id of the associated stream

  7. abstract def streamInboundAcked(count: Int): Unit

    Signal that a stream window update was sent for count bytes

  8. abstract def streamInboundWindow: Int

    Get the remaining bytes in the streams inbound window

  9. abstract def streamOutboundAcked(count: Int): Option[Http2Exception]

    Signal that a stream window update was received for count bytes

  10. abstract def streamOutboundWindow: Int

    Get the remaining bytes in the stream outbound window

  11. abstract def streamUnconsumedBytes: Int

    Get the number of stream inbound bytes that haven't been consumed

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def outboundWindow: Int

    Get the remaining outbound window, considering both the session and stream windows

  16. final def outboundWindowAvailable: Boolean

    Determine whether we have available flow window remaining, considering both the stream and the session flow windows

  17. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  18. def toString(): String
    Definition Classes
    AnyRef → Any
  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped