Package org.apache.pekko.http.impl.engine.http2

Interface Http2StreamHandling

All Superinterfaces:
org.apache.pekko.macros.LogHelper, org.apache.pekko.macros.LogHelperMacro
public interface Http2StreamHandling extends org.apache.pekko.macros.LogHelper
INTERNAL API

Handles HTTP/2 stream states Accepts FrameEvents from the network side and emits ByteHttp2SubStreams for streams to be handled by the Pekko HTTP layer.

Mixed into the Http2ServerDemux graph logic.

  • Method Details

    • Idle

      Http2StreamHandling.Idle$ Idle()
      Accessor for nested Scala object
      Returns:
      (undocumented)

    • Closed

      Http2StreamHandling.Closed$ Closed()
      Accessor for nested Scala object
      Returns:
      (undocumented)

    • OutStream

      Http2StreamHandling.OutStream$ OutStream()
      Accessor for nested Scala object
      Returns:
      (undocumented)

    • isServer

      boolean isServer()

    • multiplexer

      Http2Multiplexer multiplexer()

    • settings

      Http2CommonSettings settings()

    • pushGOAWAY

      void pushGOAWAY(Http2Protocol.ErrorCode errorCode, String debug)

    • dispatchSubstream

      void dispatchSubstream(FrameEvent.ParsedHeadersFrame initialHeaders, scala.util.Either<org.apache.pekko.util.ByteString,org.apache.pekko.stream.scaladsl.Source<Object,Object>> data, scala.collection.immutable.Map<AttributeKey<?>,Object> correlationAttributes)

    • isUpgraded

      boolean isUpgraded()

    • wrapTrailingHeaders

      scala.Option<HttpEntity.ChunkStreamPart> wrapTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)

    • flowController

      IncomingFlowController flowController()

    • tryPullSubStreams

      void tryPullSubStreams()
      Tries to generate demand of SubStreams on the inlet from the user handler. The attemp to demand will succeed if the inlet is open and has no pending pull, and, in the case of a client, if we're not exceedingthe number of active streams. This method must be invoked any time the collection of active streams or the value of maxConcurrentStreams are modified but the invocation must happen _after_ the collection or the limit are modified.

    • lastStreamId

      int lastStreamId()
      The "last peer-initiated stream that was or might be processed on the sending endpoint in this connection"

      Returns:
      (undocumented)

    • setMaxConcurrentStreams

      void setMaxConcurrentStreams(int newValue)

    • hasCapacityToCreateStreams

      boolean hasCapacityToCreateStreams()
      Returns:
      true if the number of outgoing Active streams (Active includes Open and any variant of HalfClosedXxx) doesn't exceed MaxConcurrentStreams

    • onAllStreamsClosed

      void onAllStreamsClosed()
      Called when all streams in StreamHandling buffers are closed and the stage is completing.

    • streamFor

      Http2StreamHandling.StreamState streamFor(int streamId)

    • activeStreamCount

      int activeStreamCount()

    • handleStreamEvent

      void handleStreamEvent(FrameEvent.StreamFrameEvent e)
      Called by Http2ServerDemux to let the state machine handle StreamFrameEvents

    • handleOutgoingCreated

      void handleOutgoingCreated(Http2SubStream stream)
      Called by Http2ServerDemux when a stream comes in from the user-handler

    • handleOutgoingEnded

      void handleOutgoingEnded(int streamId)

    • handleOutgoingFailed

      void handleOutgoingFailed(int streamId, Throwable cause)

    • distributeWindowDeltaToAllStreams

      void distributeWindowDeltaToAllStreams(int delta)
      Called by multiplexer to distribute changes from INITIAL_WINDOW_SIZE to all streams

    • pullNextFrame

      PullFrameResult pullNextFrame(int streamId, int maxSize)
      Called by the multiplexer if ready to send a data frame

    • incomingStreamPulled

      void incomingStreamPulled(int streamId)
      Entry-point to handle IncomingStreamBuffer.onPull through the state machine

    • updateAllStates

      void updateAllStates(scala.Function1<Http2StreamHandling.StreamState,Http2StreamHandling.StreamState> handle, String event, Object eventArg)

    • updateState

      void updateState(int streamId, scala.Function1<Http2StreamHandling.StreamState,Http2StreamHandling.StreamState> handle, String event, Object eventArg)

    • enqueueOutStream

      void enqueueOutStream(int streamId)

    • updateStateAndReturn

      <R> R updateStateAndReturn(int streamId, scala.Function1<Http2StreamHandling.StreamState,scala.Tuple2<Http2StreamHandling.StreamState,R>> handle, String event, Object eventArg)

    • shutdownStreamHandling

      void shutdownStreamHandling()
      Called to cleanup any state when the connection is torn down

    • resetStream

      void resetStream(int streamId, Http2Protocol.ErrorCode errorCode)