abstract class SessionFlowControl extends AnyRef
Flow control representation of a Http2 Session
- Annotations
- @deprecated
- Deprecated
(Since version 0.23.18) HTTP/2 support is unmaintained and will be removed in a future version.
- Source
- SessionFlowControl.scala
- Alphabetic
- By Inheritance
- SessionFlowControl
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SessionFlowControl()
Abstract Value Members
- abstract def newStreamFlowWindow(streamId: Int): StreamFlowWindow
Create a new StreamFlowWindow for a stream which will update and check the bounds of the session flow control state.
Create a new StreamFlowWindow for a stream which will update and check the bounds of the session flow control state.
- Note
the stream StreamFlowWindow is not thread safe.
- abstract def sessionInboundAcked(count: Int): Unit
Update the session inbound window
- abstract def sessionInboundConsumed(count: Int): Unit
Signal that inbound bytes have been consumed that are not tracked by a stream
- abstract def sessionInboundObserved(count: Int): Boolean
Observe inbound bytes that don't belong to an active inbound stream
Observe inbound bytes that don't belong to an active inbound stream
- count
bytes observed
- returns
trueif there was sufficient session flow window remaining,falseotherwise.
- abstract def sessionInboundWindow: Int
Get the number of bytes remaining in the inbound flow window
- abstract def sessionOutboundAcked(count: Int): Option[Http2Exception]
Update the session outbound window
Update the session outbound window
- Note
there is no way to withdraw outbound bytes directly from the session as there should always be an associated stream when sending flow control counted bytes outbound.
- abstract def sessionOutboundWindow: Int
Get the remaining bytes in the sessions outbound flow window
- abstract def sessionUnconsumedBytes: Int
Get the total number of inbound bytes that have yet to be consumed by the streams
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()