org.apache.pekko.http.impl.engine.client

Class OutgoingConnectionBlueprint.ResponseParsingMerge

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>>

org.apache.pekko.http.impl.engine.client.OutgoingConnectionBlueprint.ResponseParsingMerge

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>,org.apache.pekko.NotUsed>

Enclosing class:

OutgoingConnectionBlueprint

public static final class OutgoingConnectionBlueprint.ResponseParsingMerge
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>>

A merge that follows this logic: 1. Wait on the methodBypass for the method of the request corresponding to the next response to be received 2. Read from the dataInput until exactly one response has been fully received 3. Go back to 1.

Nested Class Summary

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
ResponseParsingMerge(HttpResponseParser rootParser)

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.stream.stage.GraphStageLogic	createLogic(org.apache.pekko.stream.Attributes effectiveAttributes)
org.apache.pekko.stream.Attributes	initialAttributes()
org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>	shape()

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

createLogicAndMaterializedValue

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

addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, 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

ResponseParsingMerge

public ResponseParsingMerge(HttpResponseParser rootParser)

Method Detail

createLogic

public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes effectiveAttributes)

Specified by:

createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>>

initialAttributes

public org.apache.pekko.stream.Attributes initialAttributes()

Overrides:

initialAttributes in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>,org.apache.pekko.NotUsed>

shape

public org.apache.pekko.stream.FanInShape2<org.apache.pekko.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>> shape()