Package 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:

Serializable, scala.Equals, scala.Product

Enclosing interface:

Http2StreamHandling

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

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Http2StreamHandling.IncomingStreamBuffer	buffer()
int	extraInitialWindow()
Http2StreamHandling.StreamState	handleOutgoingCreated(Http2StreamHandling.OutStream outStream, scala.collection.immutable.Map<AttributeKey<?>,Object> correlationAttributes)	Called when we receive a user-created stream (that is open for more data)
Http2StreamHandling.StreamState	handleOutgoingCreatedAndFinished(scala.collection.immutable.Map<AttributeKey<?>,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.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

OpenReceivingDataFirst

public OpenReceivingDataFirst(Http2StreamHandling.IncomingStreamBuffer buffer,
 int extraInitialWindow)

Method Details

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<?>,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<?>,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