Package akka.http.impl.engine.http2

Class Http2ServerDemux

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.BidiShape<Http2SubStream,FrameEvent,FrameEvent,Http2SubStream>,ServerTerminator>

akka.http.impl.engine.http2.Http2Demux

akka.http.impl.engine.http2.Http2ServerDemux

All Implemented Interfaces:

akka.stream.Graph<akka.stream.BidiShape<Http2SubStream,FrameEvent,FrameEvent,Http2SubStream>,ServerTerminator>

public class Http2ServerDemux
extends Http2Demux

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class akka.http.impl.engine.http2.Http2Demux

Http2Demux.CompletionTimeout$

Nested classes/interfaces inherited from interface akka.stream.Graph

akka.stream.Graph.GraphMapMatVal<S extends akka.stream.Shape,M extends java.lang.Object>

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class akka.http.impl.engine.http2.Http2Demux

createLogicAndMaterializedValue, frameIn, frameOut, shape, substreamIn, substreamOut

Methods inherited from class akka.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

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