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 extends 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 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

Constructor Details
- Http2ServerDemux
  
  public Http2ServerDemux(Http2ServerSettings http2Settings, scala.collection.immutable.Seq<FrameEvent.Setting> initialRemoteSettings, boolean upgraded)
Method Details
- 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