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