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

Class HostConnectionPoolSpec.PekkoHttpEngineTCP$

java.lang.Object

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

org.apache.pekko.http.impl.engine.client.HostConnectionPoolSpec.PekkoHttpEngineTCP$

All Implemented Interfaces:

java.io.Serializable, HostConnectionPoolSpec.ClientServerImplementation, scala.Equals, scala.Product

Enclosing class:

HostConnectionPoolSpec

public class HostConnectionPoolSpec.PekkoHttpEngineTCP$
extends HostConnectionPoolSpec.TopLevelApiClientServerImplementation
implements scala.Product, java.io.Serializable

Transport that uses actual top-level Http APIs to establish a plaintext HTTP connection

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static HostConnectionPoolSpec.PekkoHttpEngineTCP$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
PekkoHttpEngineTCP$()

Method Summary

Modifier and Type	Method and Description
protected org.apache.pekko.stream.scaladsl.Source<Http.IncomingConnection,scala.concurrent.Future<Http.ServerBinding>>	bindServerSource()
protected org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>>	clientConnectionFlow(Http.ServerBinding serverBinding, org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)

Methods inherited from class org.apache.pekko.http.impl.engine.client.HostConnectionPoolSpec.TopLevelApiClientServerImplementation

failsHandlerInputWhenHandlerOutputFails, get

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final HostConnectionPoolSpec.PekkoHttpEngineTCP$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

PekkoHttpEngineTCP$

public PekkoHttpEngineTCP$()

Method Detail

bindServerSource

protected org.apache.pekko.stream.scaladsl.Source<Http.IncomingConnection,scala.concurrent.Future<Http.ServerBinding>> bindServerSource()

Specified by:

bindServerSource in class HostConnectionPoolSpec.TopLevelApiClientServerImplementation

clientConnectionFlow

protected org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> clientConnectionFlow(Http.ServerBinding serverBinding,
                                                                                                                                                org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)

Specified by:

clientConnectionFlow in class HostConnectionPoolSpec.TopLevelApiClientServerImplementation