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

Class Http2StreamHandling.IncomingStreamBuffer

java.lang.Object
org.apache.pekko.http.impl.engine.http2.Http2StreamHandling.IncomingStreamBuffer
All Implemented Interfaces:
org.apache.pekko.stream.stage.OutHandler
Enclosing interface:
Http2StreamHandling
public static class Http2StreamHandling.IncomingStreamBuffer extends Object implements org.apache.pekko.stream.stage.OutHandler

  • Constructor Details

    • IncomingStreamBuffer

      public IncomingStreamBuffer(int streamId, org.apache.pekko.stream.stage.GraphStageLogic.SubSourceOutlet<Object> outlet)

  • Method Details

    • dispatchNextChunk

      public void dispatchNextChunk()

    • isDone

      public boolean isDone()

    • onDataFrame

      public void onDataFrame(FrameEvent.DataFrame data)

    • onDownstreamFinish

      public void onDownstreamFinish(Throwable cause)
      Specified by:
      onDownstreamFinish in interface org.apache.pekko.stream.stage.OutHandler

    • onPull

      public void onPull()
      Specified by:
      onPull in interface org.apache.pekko.stream.stage.OutHandler

    • onRstStreamFrame

      public void onRstStreamFrame(FrameEvent.RstStreamFrame rst)

    • onTrailingHeaders

      public void onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)

    • shutdown

      public void shutdown()
      Tears the incoming side of the stream down. Everything still buffered is dropped here, so it has to be released from the connection-level accounting like on the other discard paths: the stream-level flow control error in onDataFrame resets a single stream and leaves the connection running, so anything kept counted there would stall the whole connection for good.