Package akka.http.impl.engine.http2

Class Http2StreamHandling.IncomingStreamBuffer

java.lang.Object

akka.http.impl.engine.http2.Http2StreamHandling.IncomingStreamBuffer

All Implemented Interfaces:

akka.stream.stage.OutHandler

Enclosing interface:

Http2StreamHandling

public static class Http2StreamHandling.IncomingStreamBuffer
extends Object
implements akka.stream.stage.OutHandler

Constructor Summary

Constructors

Constructor	Description
IncomingStreamBuffer(int streamId, akka.stream.stage.GraphStageLogic.SubSourceOutlet<Object> outlet)

Method Summary

Modifier and Type	Method	Description
void	dispatchNextChunk()
boolean	isDone()
void	onDataFrame(FrameEvent.DataFrame data)
void	onDownstreamFinish(Throwable cause)
void	onPull()
void	onRstStreamFrame(FrameEvent.RstStreamFrame rst)
void	onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)
void	shutdown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.stage.OutHandler

onDownstreamFinish

Constructor Details

IncomingStreamBuffer

public IncomingStreamBuffer(int streamId,
 akka.stream.stage.GraphStageLogic.SubSourceOutlet<Object> outlet)

Method Details

dispatchNextChunk

public void dispatchNextChunk()

isDone

public boolean isDone()

onDataFrame

public void onDataFrame(FrameEvent.DataFrame data)

onDownstreamFinish

public void onDownstreamFinish(Throwable cause)

Specified by:

onDownstreamFinish in interface akka.stream.stage.OutHandler

onPull

public void onPull()

Specified by:

onPull in interface akka.stream.stage.OutHandler

onRstStreamFrame

public void onRstStreamFrame(FrameEvent.RstStreamFrame rst)

onTrailingHeaders

public void onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)

shutdown

public void shutdown()