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

Class Http2SubStream

java.lang.Object

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

All Implemented Interfaces:

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

public class Http2SubStream
extends java.lang.Object
implements scala.Product, java.io.Serializable

Represents one direction of an Http2 substream.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and 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<java.lang.Object,java.lang.Object>> data, scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes)

Method Summary

Modifier and Type	Method and Description
static Http2SubStream	apply(HttpEntity entity, FrameEvent.ParsedHeadersFrame headers, org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders, scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes)
scala.collection.immutable.Map<AttributeKey<?>,java.lang.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<java.lang.Object,java.lang.Object>>	data()
boolean	hasEntity()
FrameEvent.ParsedHeadersFrame	initialHeaders()
int	streamId()
org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame>	trailingHeaders()
Http2SubStream	withCorrelationAttributes(scala.collection.immutable.Map<AttributeKey<?>,java.lang.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.Product

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

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

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<java.lang.Object,java.lang.Object>> data,
                      scala.collection.immutable.Map<AttributeKey<?>,java.lang.Object> correlationAttributes)

Method Detail

apply

public static Http2SubStream apply(HttpEntity entity,
                                   FrameEvent.ParsedHeadersFrame headers,
                                   org.apache.pekko.util.OptionVal<FrameEvent.ParsedHeadersFrame> trailingHeaders,
                                   scala.collection.immutable.Map<AttributeKey<?>,java.lang.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<java.lang.Object,java.lang.Object>> data()

correlationAttributes

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

streamId

public int streamId()

hasEntity

public boolean hasEntity()

withCorrelationAttributes

public Http2SubStream withCorrelationAttributes(scala.collection.immutable.Map<AttributeKey<?>,java.lang.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)