Package akka.http.impl.engine.client
Class OutgoingConnectionBlueprint.ResponseParsingMerge
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,akka.NotUsed>
-
- akka.stream.stage.GraphStage<akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>>
-
- akka.http.impl.engine.client.OutgoingConnectionBlueprint.ResponseParsingMerge
-
- All Implemented Interfaces:
akka.stream.Graph<akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>,akka.NotUsed>
- Enclosing class:
- OutgoingConnectionBlueprint
public static final class OutgoingConnectionBlueprint.ResponseParsingMerge extends akka.stream.stage.GraphStage<akka.stream.FanInShape2<akka.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.
-
-
Constructor Summary
Constructors Constructor Description ResponseParsingMerge(HttpResponseParser rootParser)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description akka.stream.stage.GraphStageLogic
createLogic(akka.stream.Attributes effectiveAttributes)
akka.stream.Attributes
initialAttributes()
akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>
shape()
-
-
-
Constructor Detail
-
ResponseParsingMerge
public ResponseParsingMerge(HttpResponseParser rootParser)
-
-
Method Detail
-
createLogic
public akka.stream.stage.GraphStageLogic createLogic(akka.stream.Attributes effectiveAttributes)
- Specified by:
createLogic
in classakka.stream.stage.GraphStage<akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>>
-
initialAttributes
public akka.stream.Attributes initialAttributes()
- Overrides:
initialAttributes
in classakka.stream.stage.GraphStageWithMaterializedValue<akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>,akka.NotUsed>
-
shape
public akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>> shape()
-
-