public static class Http2StreamHandling.IncomingStreamBuffer
extends java.lang.Object
implements org.apache.pekko.stream.stage.OutHandler
Constructor and Description |
---|
IncomingStreamBuffer(int streamId,
org.apache.pekko.stream.stage.GraphStageLogic.SubSourceOutlet<java.lang.Object> outlet) |
Modifier and Type | Method and Description |
---|---|
void |
dispatchNextChunk() |
boolean |
isDone() |
void |
onDataFrame(FrameEvent.DataFrame data) |
void |
onDownstreamFinish() |
void |
onPull() |
void |
onRstStreamFrame(FrameEvent.RstStreamFrame rst) |
void |
onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers) |
void |
shutdown() |
public IncomingStreamBuffer(int streamId, org.apache.pekko.stream.stage.GraphStageLogic.SubSourceOutlet<java.lang.Object> outlet)
public void dispatchNextChunk()
public boolean isDone()
public void onDataFrame(FrameEvent.DataFrame data)
public void onDownstreamFinish()
onDownstreamFinish
in interface org.apache.pekko.stream.stage.OutHandler
public void onPull()
onPull
in interface org.apache.pekko.stream.stage.OutHandler
public void onRstStreamFrame(FrameEvent.RstStreamFrame rst)
public void onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)
public void shutdown()