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

Class Http2SubStream

java.lang.Object

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

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class Http2SubStream
extends Object
implements scala.Product, Serializable

Represents one direction of an Http2 substream.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Http2SubStream(FrameEvent.ParsedHeadersFrame initialHeaders, org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders, scala.util.Either<org.apache.pekko.util.ByteString,org.apache.pekko.stream.scaladsl.Source<Object,Object>> data, scala.collection.immutable.Map<AttributeKey<?>,Object> correlationAttributes)

Method Summary

Modifier and Type	Method	Description
static Http2SubStream	apply(HttpEntity entity, FrameEvent.ParsedHeadersFrame headers, org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders, scala.collection.immutable.Map<AttributeKey<?>,Object> correlationAttributes)
scala.collection.immutable.Map<AttributeKey<?>,Object>	correlationAttributes()
RequestEntity	createEntity(long contentLength, org.apache.pekko.util.OptionVal<ContentType> contentTypeOption)	Create the request entity (when we're the server) or response entity (when we're the client) for this substream
scala.util.Either<org.apache.pekko.util.ByteString,org.apache.pekko.stream.scaladsl.Source<Object,Object>>	data()
boolean	hasEntity()
FrameEvent.ParsedHeadersFrame	initialHeaders()
int	streamId()
org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame>	trailingHeaders()
Http2SubStream	withCorrelationAttributes(scala.collection.immutable.Map<AttributeKey<?>,Object> newAttributes)

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

Http2SubStream

public Http2SubStream(FrameEvent.ParsedHeadersFrame initialHeaders,
 org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders,
 scala.util.Either<org.apache.pekko.util.ByteString,org.apache.pekko.stream.scaladsl.Source<Object,Object>> data,
 scala.collection.immutable.Map<AttributeKey<?>,Object> correlationAttributes)

Method Details

apply

public static Http2SubStream apply(HttpEntity entity,
 FrameEvent.ParsedHeadersFrame headers,
 org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders,
 scala.collection.immutable.Map<AttributeKey<?>,Object> correlationAttributes)

initialHeaders

public FrameEvent.ParsedHeadersFrame initialHeaders()

trailingHeaders

public org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders()

data

public scala.util.Either<org.apache.pekko.util.ByteString,org.apache.pekko.stream.scaladsl.Source<Object,Object>> data()

correlationAttributes

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

streamId

public int streamId()

hasEntity

public boolean hasEntity()

withCorrelationAttributes

public Http2SubStream withCorrelationAttributes(scala.collection.immutable.Map<AttributeKey<?>,Object> newAttributes)

createEntity

public RequestEntity createEntity(long contentLength,
 org.apache.pekko.util.OptionVal<ContentType> contentTypeOption)

Create the request entity (when we're the server) or response entity (when we're the client) for this substream

Parameters:

contentLength - (undocumented)

contentTypeOption - (undocumented)

Returns:

(undocumented)