Package akka.http.impl.engine.http2
Class Http2StreamHandling.CollectingIncomingData
java.lang.Object
akka.http.impl.engine.http2.Http2StreamHandling.StreamState
akka.http.impl.engine.http2.Http2StreamHandling.ReceivingData
akka.http.impl.engine.http2.Http2StreamHandling.CollectingIncomingData
- All Implemented Interfaces:
Serializable
,scala.Equals
,scala.Product
- Enclosing interface:
- Http2StreamHandling
public static class Http2StreamHandling.CollectingIncomingData
extends Http2StreamHandling.ReceivingData
implements scala.Product, Serializable
Special state that allows collecting some incoming data before dispatching it either as strict or streamed entity
- See Also:
-
Constructor Summary
ConstructorDescriptionCollectingIncomingData
(FrameEvent.ParsedHeadersFrame headers, scala.collection.immutable.Map<AttributeKey<?>, Object> correlationAttributes, akka.util.ByteString collectedData, int extraInitialWindow) -
Method Summary
Modifier and TypeMethodDescriptionakka.util.ByteString
scala.collection.immutable.Map<AttributeKey<?>,
Object> int
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 akka.http.impl.engine.http2.Http2StreamHandling.ReceivingData
handle
Methods inherited from class akka.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.Equals
canEqual, equals
Methods inherited from interface scala.Product
productArity, productElement, productElementName, productElementNames, productIterator, productPrefix
-
Constructor Details
-
CollectingIncomingData
public CollectingIncomingData(FrameEvent.ParsedHeadersFrame headers, scala.collection.immutable.Map<AttributeKey<?>, Object> correlationAttributes, akka.util.ByteString collectedData, int extraInitialWindow)
-
-
Method Details
-
headers
-
correlationAttributes
-
collectedData
public akka.util.ByteString collectedData() -
extraInitialWindow
public int extraInitialWindow() -
onDataFrame
- Specified by:
onDataFrame
in classHttp2StreamHandling.ReceivingData
-
onTrailer
protected Http2StreamHandling.StreamState onTrailer(FrameEvent.ParsedHeadersFrame parsedHeadersFrame) - Specified by:
onTrailer
in classHttp2StreamHandling.ReceivingData
-
incrementWindow
- Specified by:
incrementWindow
in classHttp2StreamHandling.ReceivingData
-
onRstStreamFrame
- Specified by:
onRstStreamFrame
in classHttp2StreamHandling.ReceivingData
-