org.apache.pekko.http.impl.engine.http2

Class Http2StreamHandling.IncomingStreamBuffer

java.lang.Object

org.apache.pekko.http.impl.engine.http2.Http2StreamHandling.IncomingStreamBuffer

All Implemented Interfaces:

org.apache.pekko.stream.stage.OutHandler

Enclosing interface:

Http2StreamHandling

public static class Http2StreamHandling.IncomingStreamBuffer
extends java.lang.Object
implements org.apache.pekko.stream.stage.OutHandler

Constructor Summary

Constructors

Constructor and Description
IncomingStreamBuffer(int streamId, org.apache.pekko.stream.stage.GraphStageLogic.SubSourceOutlet<java.lang.Object> outlet)

Method Summary

Modifier and Type	Method and Description
void	dispatchNextChunk()
boolean	isDone()
void	onDataFrame(FrameEvent.DataFrame data)
void	onDownstreamFinish(java.lang.Throwable cause)
void	onPull()
void	onRstStreamFrame(FrameEvent.RstStreamFrame rst)
void	onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)
void	shutdown() Tears the incoming side of the stream down.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.stream.stage.OutHandler

$init$, onDownstreamFinish

Constructor Detail

IncomingStreamBuffer

public IncomingStreamBuffer(int streamId,
                            org.apache.pekko.stream.stage.GraphStageLogic.SubSourceOutlet<java.lang.Object> outlet)

Method Detail

dispatchNextChunk

public void dispatchNextChunk()

isDone

public boolean isDone()

onDataFrame

public void onDataFrame(FrameEvent.DataFrame data)

onDownstreamFinish

public void onDownstreamFinish(java.lang.Throwable cause)

Specified by:

onDownstreamFinish in interface org.apache.pekko.stream.stage.OutHandler

onPull

public void onPull()

Specified by:

onPull in interface org.apache.pekko.stream.stage.OutHandler

onRstStreamFrame

public void onRstStreamFrame(FrameEvent.RstStreamFrame rst)

onTrailingHeaders

public void onTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)

shutdown

public void shutdown()

Tears the incoming side of the stream down. Everything still buffered is dropped here, so it has to be released from the connection-level accounting like on the other discard paths: the stream-level flow control error in onDataFrame resets a single stream and leaves the connection running, so anything kept counted there would stall the whole connection for good.