Http2ClientDemux

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.Http2ClientDemux

All Implemented Interfaces:: org.apache.pekko.stream.Graph<org.apache.pekko.stream.BidiShape<Http2SubStream,FrameEvent,FrameEvent,Http2SubStream>,ServerTerminator>

public class Http2ClientDemux 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

Http2ClientDemux(Http2ClientSettings http2Settings, HttpHeaderParser masterHttpHeaderParser)
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
- Http2ClientDemux
  
  public Http2ClientDemux(Http2ClientSettings http2Settings, HttpHeaderParser masterHttpHeaderParser)
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