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

Class OutgoingConnectionBlueprint.PrepareResponse

java.lang.Object

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

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<ParserOutput.ResponseOutput,HttpResponse>>

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

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.FlowShape<ParserOutput.ResponseOutput,HttpResponse>,org.apache.pekko.NotUsed>

Enclosing class:

OutgoingConnectionBlueprint

public static final class OutgoingConnectionBlueprint.PrepareResponse
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.FlowShape<ParserOutput.ResponseOutput,HttpResponse>>

This is essentially a three state state machine, it is either 'idle' - waiting for a response to come in or has seen the start of a response and is waiting for either chunks followed by MessageEnd if chunked or just MessageEnd in the case of a strict response.

For chunked responses a new substream into the response entity is opened and data is streamed there instead of downstream until end of chunks has been reached.

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
PrepareResponse(ParserSettings parserSettings)

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.FlowShape<ParserOutput.ResponseOutput,HttpResponse>	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, initialAttributes, 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

PrepareResponse

public PrepareResponse(ParserSettings parserSettings)

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.FlowShape<ParserOutput.ResponseOutput,HttpResponse>>

shape

public org.apache.pekko.stream.FlowShape<ParserOutput.ResponseOutput,HttpResponse> shape()