public static class Http2StreamHandling.IncomingStreamBuffer
extends java.lang.Object
implements akka.stream.stage.OutHandler
Constructor and Description |
---|
IncomingStreamBuffer(int streamId,
akka.stream.stage.GraphStageLogic.SubSourceOutlet<akka.util.ByteString> outlet) |
Modifier and Type | Method and Description |
---|---|
scala.Option<Http2StreamHandling.IncomingStreamState> |
onDataFrame(FrameEvent.DataFrame data) |
void |
onDownstreamFinish() |
void |
onPull() |
void |
onRstStreamFrame(FrameEvent.RstStreamFrame rst) |
void |
shutdown() |
public IncomingStreamBuffer(int streamId, akka.stream.stage.GraphStageLogic.SubSourceOutlet<akka.util.ByteString> outlet)
public scala.Option<Http2StreamHandling.IncomingStreamState> onDataFrame(FrameEvent.DataFrame data)
public void onDownstreamFinish()
onDownstreamFinish
in interface akka.stream.stage.OutHandler
public void onPull()
onPull
in interface akka.stream.stage.OutHandler
public void onRstStreamFrame(FrameEvent.RstStreamFrame rst)
public void shutdown()