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 java.lang.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()
boolean	increaseWindow(int increment)
boolean	isDone()
FrameEvent.DataFrame	nextFrame(int maxBytesToSend)
void	onPush()
void	onUpstreamFailure(java.lang.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 Detail

OutStreamImpl

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

Method Detail

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 boolean increaseWindow(int increment)

Specified by:

increaseWindow in interface Http2StreamHandling.OutStream

Parameters:

increment - (undocumented)

Returns:

true if the window was increased, false if it would have exceeded the maximum allowed value (2^31-1), in which case the window was left untouched

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(java.lang.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()

Specified by:

streamId in interface Http2StreamHandling.OutStream

trailer

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