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

Class HttpsProxyGraphStage

java.lang.Object

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

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>

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

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.BidiShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>,org.apache.pekko.NotUsed>

public final class HttpsProxyGraphStage
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HttpsProxyGraphStage.Connected$
static class	HttpsProxyGraphStage.Connecting$
static class	HttpsProxyGraphStage.Starting$
static interface	HttpsProxyGraphStage.State

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
HttpsProxyGraphStage(java.lang.String targetHostName, int targetPort, ClientConnectionSettings settings, scala.Option<HttpCredentials> proxyAuthorization)

Method Summary

Modifier and Type	Method and Description
static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed>	apply(java.lang.String targetHostName, int targetPort, ClientConnectionSettings settings, scala.Option<HttpCredentials> proxyAuth)
org.apache.pekko.stream.Inlet<org.apache.pekko.util.ByteString>	bytesIn()
org.apache.pekko.stream.Outlet<org.apache.pekko.util.ByteString>	bytesOut()
org.apache.pekko.stream.stage.GraphStageLogic	createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)
org.apache.pekko.stream.BidiShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>	shape()
org.apache.pekko.stream.Inlet<org.apache.pekko.util.ByteString>	sslIn()
org.apache.pekko.stream.Outlet<org.apache.pekko.util.ByteString>	sslOut()

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

HttpsProxyGraphStage

public HttpsProxyGraphStage(java.lang.String targetHostName,
                            int targetPort,
                            ClientConnectionSettings settings,
                            scala.Option<HttpCredentials> proxyAuthorization)

Method Detail

apply

public static org.apache.pekko.stream.scaladsl.BidiFlow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> apply(java.lang.String targetHostName,
                                                                                                                                                                                                                            int targetPort,
                                                                                                                                                                                                                            ClientConnectionSettings settings,
                                                                                                                                                                                                                            scala.Option<HttpCredentials> proxyAuth)

bytesIn

public org.apache.pekko.stream.Inlet<org.apache.pekko.util.ByteString> bytesIn()

bytesOut

public org.apache.pekko.stream.Outlet<org.apache.pekko.util.ByteString> bytesOut()

sslIn

public org.apache.pekko.stream.Inlet<org.apache.pekko.util.ByteString> sslIn()

sslOut

public org.apache.pekko.stream.Outlet<org.apache.pekko.util.ByteString> sslOut()

shape

public org.apache.pekko.stream.BidiShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString> shape()

createLogic

public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes inheritedAttributes)

Specified by:

createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString>>