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

Class Http2StreamHandling.CollectingIncomingData

java.lang.Object

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

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

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

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing interface:

Http2StreamHandling

public static class Http2StreamHandling.CollectingIncomingData
extends Http2StreamHandling.ReceivingData
implements scala.Product, java.io.Serializable

Special state that allows collecting some incoming data before dispatching it either as strict or streamed entity

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CollectingIncomingData(FrameEvent.ParsedHeadersFrame headers, scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes, org.apache.pekko.util.ByteString collectedData, int extraInitialWindow)

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.util.ByteString	collectedData()
scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object>	correlationAttributes()
int	extraInitialWindow()
FrameEvent.ParsedHeadersFrame	headers()
protected Http2StreamHandling.StreamState	incrementWindow(int delta)
protected Http2StreamHandling.StreamState	onDataFrame(FrameEvent.DataFrame dataFrame)
protected void	onRstStreamFrame(FrameEvent.RstStreamFrame rstStreamFrame)
protected Http2StreamHandling.StreamState	onTrailer(FrameEvent.ParsedHeadersFrame parsedHeadersFrame)

Methods inherited from class org.apache.pekko.http.impl.engine.http2.Http2StreamHandling.ReceivingData

handle

Methods inherited from class org.apache.pekko.http.impl.engine.http2.Http2StreamHandling.StreamState

dispatchStream, expectIncomingStream, handleOutgoingCreated, handleOutgoingCreatedAndFinished, handleOutgoingEnded, handleOutgoingFailed, incomingStreamPulled, pullNextFrame, receivedUnexpectedFrame, shutdown, stateName

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

CollectingIncomingData

public CollectingIncomingData(FrameEvent.ParsedHeadersFrame headers,
                              scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes,
                              org.apache.pekko.util.ByteString collectedData,
                              int extraInitialWindow)

Method Detail

headers

public FrameEvent.ParsedHeadersFrame headers()

correlationAttributes

public scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes()

collectedData

public org.apache.pekko.util.ByteString collectedData()

extraInitialWindow

public int extraInitialWindow()

onDataFrame

protected Http2StreamHandling.StreamState onDataFrame(FrameEvent.DataFrame dataFrame)

Specified by:

onDataFrame in class Http2StreamHandling.ReceivingData

onTrailer

protected Http2StreamHandling.StreamState onTrailer(FrameEvent.ParsedHeadersFrame parsedHeadersFrame)

Specified by:

onTrailer in class Http2StreamHandling.ReceivingData

incrementWindow

protected Http2StreamHandling.StreamState incrementWindow(int delta)

Specified by:

incrementWindow in class Http2StreamHandling.ReceivingData

onRstStreamFrame

protected void onRstStreamFrame(FrameEvent.RstStreamFrame rstStreamFrame)

Specified by:

onRstStreamFrame in class Http2StreamHandling.ReceivingData