public static final class Http2StreamHandling.OutStreamImpl extends java.lang.Object implements org.apache.pekko.stream.stage.InHandler, Http2StreamHandling.OutStream
Constructor and Description |
---|
OutStreamImpl(int streamId,
org.apache.pekko.util.OptionVal<org.apache.pekko.stream.stage.GraphStageLogic.SubSinkInlet<?>> maybeInlet,
int outboundWindowLeft,
org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailer) |
Modifier and Type | Method and Description |
---|---|
void |
addAllData(org.apache.pekko.util.ByteString data) |
int |
bufferedBytes() |
void |
cancelStream() |
boolean |
canSend()
Designates whether nextFrame can be called to get the next frame.
|
scala.Option<FrameEvent> |
endStreamIfPossible() |
boolean |
endStreamSent() |
void |
enqueueIfPossible() |
void |
increaseWindow(int increment) |
boolean |
isDone() |
FrameEvent.DataFrame |
nextFrame(int maxBytesToSend) |
void |
onPush() |
void |
onUpstreamFailure(java.lang.Throwable ex) |
void |
onUpstreamFinish() |
int |
outboundWindowLeft() |
void |
registerIncomingData(org.apache.pekko.stream.stage.GraphStageLogic.SubSinkInlet<?> inlet) |
int |
streamId() |
org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> |
trailer() |
public OutStreamImpl(int streamId, org.apache.pekko.util.OptionVal<org.apache.pekko.stream.stage.GraphStageLogic.SubSinkInlet<?>> maybeInlet, int outboundWindowLeft, org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailer)
public void addAllData(org.apache.pekko.util.ByteString data)
public int bufferedBytes()
public boolean canSend()
canSend
in interface Http2StreamHandling.OutStream
public void cancelStream()
cancelStream
in interface Http2StreamHandling.OutStream
public scala.Option<FrameEvent> endStreamIfPossible()
endStreamIfPossible
in interface Http2StreamHandling.OutStream
public boolean endStreamSent()
public void enqueueIfPossible()
public void increaseWindow(int increment)
increaseWindow
in interface Http2StreamHandling.OutStream
public boolean isDone()
isDone
in interface Http2StreamHandling.OutStream
public FrameEvent.DataFrame nextFrame(int maxBytesToSend)
nextFrame
in interface Http2StreamHandling.OutStream
public void onPush()
onPush
in interface org.apache.pekko.stream.stage.InHandler
public void onUpstreamFailure(java.lang.Throwable ex)
onUpstreamFailure
in interface org.apache.pekko.stream.stage.InHandler
public void onUpstreamFinish()
onUpstreamFinish
in interface org.apache.pekko.stream.stage.InHandler
public int outboundWindowLeft()
public void registerIncomingData(org.apache.pekko.stream.stage.GraphStageLogic.SubSinkInlet<?> inlet)
public int streamId()
public org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailer()