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>>>
Constructor and Description |
---|
ResponseParsingMerge(HttpResponseParser rootParser) |
Modifier and Type | Method and 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() |
addAttributes, async, async, async, createLogicAndMaterializedValue, named, traversalBuilder, withAttributes
public ResponseParsingMerge(HttpResponseParser rootParser)
public akka.stream.stage.GraphStageLogic createLogic(akka.stream.Attributes effectiveAttributes)
createLogic
in class akka.stream.stage.GraphStage<akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>>
public akka.stream.Attributes initialAttributes()
initialAttributes
in class akka.stream.stage.GraphStageWithMaterializedValue<akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>>,akka.NotUsed>
public akka.stream.FanInShape2<akka.stream.TLSProtocol.SessionBytes,HttpResponseParser.ResponseContext,scala.collection.immutable.List<ParserOutput.ResponseOutput>> shape()