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

Class Http2ServerDemux

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.BidiShape<Http2SubStream,FrameEvent,FrameEvent,Http2SubStream>,ServerTerminator>

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

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

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.BidiShape<Http2SubStream,FrameEvent,FrameEvent,Http2SubStream>,ServerTerminator>

public class Http2ServerDemux
extends Http2Demux

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.http.impl.engine.http2.Http2Demux

Http2Demux.CompletionTimeout$

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M>

Constructor Summary

Constructors

Constructor and Description
Http2ServerDemux(Http2ServerSettings http2Settings, scala.collection.immutable.Seq<FrameEvent.Setting> initialRemoteSettings, boolean upgraded)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.FiniteDuration	completionTimeout()
scala.Option<HttpEntity.ChunkStreamPart>	wrapTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)

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

createLogicAndMaterializedValue, frameIn, frameOut, shape, substreamIn, substreamOut

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, initialAttributes, named, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

Http2ServerDemux

public Http2ServerDemux(Http2ServerSettings http2Settings,
                        scala.collection.immutable.Seq<FrameEvent.Setting> initialRemoteSettings,
                        boolean upgraded)

Method Detail

completionTimeout

public scala.concurrent.duration.FiniteDuration completionTimeout()

Specified by:

completionTimeout in class Http2Demux

wrapTrailingHeaders

public scala.Option<HttpEntity.ChunkStreamPart> wrapTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)

Specified by:

wrapTrailingHeaders in class Http2Demux