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:: Serializable, HostConnectionPoolSpec.ClientServerImplementation, scala.Equals, scala.Product

Enclosing class:: HostConnectionPoolSpec

public class HostConnectionPoolSpec.PekkoHttpEngineTCP$ extends HostConnectionPoolSpec.TopLevelApiClientServerImplementation implements scala.Product, 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

Description

static final HostConnectionPoolSpec.PekkoHttpEngineTCP$

MODULE$

Static reference to the singleton instance of this Scala object.
Constructor Summary

Constructors

Constructor

Description

PekkoHttpEngineTCP$()
Method Summary

Modifier and Type

Method

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.Equals
canEqual, equals

Methods inherited from interface scala.Product
productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Field Details
- MODULE$
  
  public static final HostConnectionPoolSpec.PekkoHttpEngineTCP$ MODULE$
  
  Static reference to the singleton instance of this Scala object.
Constructor Details
- PekkoHttpEngineTCP$
  
  public PekkoHttpEngineTCP$()
Method Details
- 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