Package akka.http.impl.engine.http2

Class Http2StreamHandling.OutStreamImpl

java.lang.Object

akka.http.impl.engine.http2.Http2StreamHandling.OutStreamImpl

All Implemented Interfaces:

Http2StreamHandling.OutStream, akka.stream.stage.InHandler

Enclosing interface:

Http2StreamHandling

public static final class Http2StreamHandling.OutStreamImpl
extends Object
implements akka.stream.stage.InHandler, Http2StreamHandling.OutStream

Constructor Summary

Constructors

Constructor	Description
OutStreamImpl(int streamId, akka.util.OptionVal<akka.stream.stage.GraphStageLogic.SubSinkInlet<?>> maybeInlet, int outboundWindowLeft, akka.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailer)

Method Summary

Modifier and Type	Method	Description
void	addAllData(akka.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(Throwable ex)
void	onUpstreamFinish()
int	outboundWindowLeft()
void	registerIncomingData(akka.stream.stage.GraphStageLogic.SubSinkInlet<?> inlet)
int	streamId()
akka.util.OptionVal<FrameEvent.ParsedHeadersFrame>	trailer()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OutStreamImpl

public OutStreamImpl(int streamId,
 akka.util.OptionVal<akka.stream.stage.GraphStageLogic.SubSinkInlet<?>> maybeInlet,
 int outboundWindowLeft,
 akka.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailer)

Method Details

addAllData

public void addAllData(akka.util.ByteString data)

bufferedBytes

public int bufferedBytes()

canSend

public boolean canSend()

Designates whether nextFrame can be called to get the next frame.

Specified by:

canSend in interface Http2StreamHandling.OutStream

cancelStream

public void cancelStream()

Specified by:

cancelStream in interface Http2StreamHandling.OutStream

endStreamIfPossible

public scala.Option<FrameEvent> endStreamIfPossible()

Specified by:

endStreamIfPossible in interface Http2StreamHandling.OutStream

endStreamSent

public boolean endStreamSent()

enqueueIfPossible

public void enqueueIfPossible()

increaseWindow

public void increaseWindow(int increment)

Specified by:

increaseWindow in interface Http2StreamHandling.OutStream

isDone

public boolean isDone()

Specified by:

isDone in interface Http2StreamHandling.OutStream

nextFrame

public FrameEvent.DataFrame nextFrame(int maxBytesToSend)

Specified by:

nextFrame in interface Http2StreamHandling.OutStream

onPush

public void onPush()

Specified by:

onPush in interface akka.stream.stage.InHandler

onUpstreamFailure

public void onUpstreamFailure(Throwable ex)

Specified by:

onUpstreamFailure in interface akka.stream.stage.InHandler

onUpstreamFinish

public void onUpstreamFinish()

Specified by:

onUpstreamFinish in interface akka.stream.stage.InHandler

outboundWindowLeft

public int outboundWindowLeft()

registerIncomingData

public void registerIncomingData(akka.stream.stage.GraphStageLogic.SubSinkInlet<?> inlet)

streamId

public int streamId()

trailer

public akka.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailer()