public final class HttpsProxyGraphStage
extends akka.stream.stage.GraphStage<akka.stream.BidiShape<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString>>
Modifier and Type | Class and Description |
---|---|
static class |
HttpsProxyGraphStage.Connected$ |
static class |
HttpsProxyGraphStage.Connecting$ |
static class |
HttpsProxyGraphStage.Starting$ |
static interface |
HttpsProxyGraphStage.State |
Constructor and Description |
---|
HttpsProxyGraphStage(java.lang.String targetHostName,
int targetPort,
ClientConnectionSettings settings,
scala.Option<HttpCredentials> proxyAuthorization) |
Modifier and Type | Method and Description |
---|---|
static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.NotUsed> |
apply(java.lang.String targetHostName,
int targetPort,
ClientConnectionSettings settings,
scala.Option<HttpCredentials> proxyAuth) |
akka.stream.Inlet<akka.util.ByteString> |
bytesIn() |
akka.stream.Outlet<akka.util.ByteString> |
bytesOut() |
akka.stream.stage.GraphStageLogic |
createLogic(akka.stream.Attributes inheritedAttributes) |
akka.stream.BidiShape<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString> |
shape() |
akka.stream.Inlet<akka.util.ByteString> |
sslIn() |
akka.stream.Outlet<akka.util.ByteString> |
sslOut() |
addAttributes, async, initialAttributes, module, named, withAttributes
public HttpsProxyGraphStage(java.lang.String targetHostName, int targetPort, ClientConnectionSettings settings, scala.Option<HttpCredentials> proxyAuthorization)
public static akka.stream.scaladsl.BidiFlow<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.NotUsed> apply(java.lang.String targetHostName, int targetPort, ClientConnectionSettings settings, scala.Option<HttpCredentials> proxyAuth)
public akka.stream.Inlet<akka.util.ByteString> bytesIn()
public akka.stream.Outlet<akka.util.ByteString> bytesOut()
public akka.stream.Inlet<akka.util.ByteString> sslIn()
public akka.stream.Outlet<akka.util.ByteString> sslOut()
public akka.stream.BidiShape<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString> shape()
public akka.stream.stage.GraphStageLogic createLogic(akka.stream.Attributes inheritedAttributes)
createLogic
in class akka.stream.stage.GraphStage<akka.stream.BidiShape<akka.util.ByteString,akka.util.ByteString,akka.util.ByteString,akka.util.ByteString>>