Class 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.
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface akka.stream.Graph

        akka.stream.Graph.GraphMapMatVal<S extends akka.stream.Shape,​M extends java.lang.Object>
    • 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()  
      • Methods inherited from class akka.stream.stage.GraphStage

        createLogicAndMaterializedValue
      • Methods inherited from class akka.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