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

Class Http2StreamHandling.OpenReceivingDataFirst

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.ReceivingDataWithBuffer

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

All Implemented Interfaces:

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

Enclosing interface:

Http2StreamHandling

public static class Http2StreamHandling.OpenReceivingDataFirst
extends Http2StreamHandling.ReceivingDataWithBuffer
implements scala.Product, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OpenReceivingDataFirst(Http2StreamHandling.IncomingStreamBuffer buffer, int extraInitialWindow)

Method Summary

Modifier and Type	Method and Description
Http2StreamHandling.IncomingStreamBuffer	buffer()
int	extraInitialWindow()
Http2StreamHandling.StreamState	handleOutgoingCreated(Http2StreamHandling.OutStream outStream, scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes) Called when we receive a user-created stream (that is open for more data)
Http2StreamHandling.StreamState	handleOutgoingCreatedAndFinished(scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes) Called when we receive a user-created stream that is already closed
Http2StreamHandling.StreamState	handleOutgoingEnded()
Http2StreamHandling.StreamState	incrementWindow(int delta)

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

afterBufferEvent, incomingStreamPulled, onDataFrame, onRstStreamFrame, onTrailer, shutdown

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, handleOutgoingFailed, pullNextFrame, receivedUnexpectedFrame, 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

OpenReceivingDataFirst

public OpenReceivingDataFirst(Http2StreamHandling.IncomingStreamBuffer buffer,
                              int extraInitialWindow)

Method Detail

buffer

public Http2StreamHandling.IncomingStreamBuffer buffer()

Specified by:

buffer in class Http2StreamHandling.ReceivingDataWithBuffer

extraInitialWindow

public int extraInitialWindow()

handleOutgoingCreated

public Http2StreamHandling.StreamState handleOutgoingCreated(Http2StreamHandling.OutStream outStream,
                                                             scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes)

Description copied from class: Http2StreamHandling.StreamState

Called when we receive a user-created stream (that is open for more data)

Overrides:

handleOutgoingCreated in class Http2StreamHandling.StreamState

handleOutgoingCreatedAndFinished

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

Description copied from class: Http2StreamHandling.StreamState

Called when we receive a user-created stream that is already closed

Overrides:

handleOutgoingCreatedAndFinished in class Http2StreamHandling.StreamState

handleOutgoingEnded

public Http2StreamHandling.StreamState handleOutgoingEnded()

Overrides:

handleOutgoingEnded in class Http2StreamHandling.StreamState

incrementWindow

public Http2StreamHandling.StreamState incrementWindow(int delta)

Specified by:

incrementWindow in class Http2StreamHandling.ReceivingDataWithBuffer