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

Class OutgoingConnectionBlueprint

java.lang.Object

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

public class OutgoingConnectionBlueprint
extends Object

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	OutgoingConnectionBlueprint.PrepareResponse	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.
static final class	OutgoingConnectionBlueprint.ResponseParsingMerge	A merge that follows this logic: 1.
static class	OutgoingConnectionBlueprint.UnexpectedConnectionClosureException

Constructor Summary

Constructors

Constructor	Description
OutgoingConnectionBlueprint()

Method Summary

Modifier and Type	Method	Description
static org.apache.pekko.stream.scaladsl.BidiFlow<HttpRequest,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,HttpResponse,org.apache.pekko.NotUsed>	apply(Host hostHeader, ClientConnectionSettings settings, org.apache.pekko.event.LoggingAdapter log)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OutgoingConnectionBlueprint

public OutgoingConnectionBlueprint()

Method Details

apply

public static org.apache.pekko.stream.scaladsl.BidiFlow<HttpRequest,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,HttpResponse,org.apache.pekko.NotUsed> apply(Host hostHeader,
 ClientConnectionSettings settings,
 org.apache.pekko.event.LoggingAdapter log)