Package akka.http.impl.engine.http2
Class Http2ClientDemux
- 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.Http2ClientDemux
-
- All Implemented Interfaces:
akka.stream.Graph<akka.stream.BidiShape<Http2SubStream,FrameEvent,FrameEvent,Http2SubStream>,ServerTerminator>
public class Http2ClientDemux extends Http2Demux
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.http.impl.engine.http2.Http2Demux
Http2Demux.CompletionTimeout$
-
-
Constructor Summary
Constructors Constructor Description Http2ClientDemux(Http2ClientSettings http2Settings, HttpHeaderParser masterHttpHeaderParser)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Constructor Detail
-
Http2ClientDemux
public Http2ClientDemux(Http2ClientSettings http2Settings, HttpHeaderParser masterHttpHeaderParser)
-
-
Method Detail
-
completionTimeout
public scala.concurrent.duration.FiniteDuration completionTimeout()
- Specified by:
completionTimeout
in classHttp2Demux
-
wrapTrailingHeaders
public scala.Option<HttpEntity.ChunkStreamPart> wrapTrailingHeaders(FrameEvent.ParsedHeadersFrame headers)
- Specified by:
wrapTrailingHeaders
in classHttp2Demux
-
-