Class Http2StreamHandling.IncomingStreamBuffer

  • All Implemented Interfaces:
    akka.stream.stage.OutHandler
    Enclosing interface:
    Http2StreamHandling

    public static class Http2StreamHandling.IncomingStreamBuffer
    extends java.lang.Object
    implements akka.stream.stage.OutHandler
    • Constructor Detail

      • IncomingStreamBuffer

        public IncomingStreamBuffer​(int streamId,
                                    akka.stream.stage.GraphStageLogic.SubSourceOutlet<java.lang.Object> outlet)
    • Method Detail

      • dispatchNextChunk

        public void dispatchNextChunk()
      • isDone

        public boolean isDone()
      • onDownstreamFinish

        public void onDownstreamFinish​(java.lang.Throwable cause)
        Specified by:
        onDownstreamFinish in interface akka.stream.stage.OutHandler
      • onPull

        public void onPull()
        Specified by:
        onPull in interface akka.stream.stage.OutHandler
      • shutdown

        public void shutdown()