HostConnectionPoolSpec.PekkoHttpEngineTCP

java.lang.Object

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

Enclosing class:: HostConnectionPoolSpec

public class HostConnectionPoolSpec.PekkoHttpEngineTCP extends Object

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

Constructor Summary

Constructors

Constructor

Description

PekkoHttpEngineTCP()
Method Summary

Modifier and Type

Method

Description

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

bindServerSource()

abstract static boolean

canEqual(Object that)

protected static org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>>

clientConnectionFlow(Http.ServerBinding serverBinding, org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)

abstract static boolean

equals(Object that)

static boolean

failsHandlerInputWhenHandlerOutputFails()

static org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,scala.concurrent.Future<Http.OutgoingConnection>>

get(org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)

abstract static int

productArity()

abstract static Object

productElement(int n)

static String

productElementName(int n)

static scala.collection.Iterator<String>

productElementNames()

static scala.collection.Iterator<Object>

productIterator()

static String

productPrefix()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- PekkoHttpEngineTCP
  
  public PekkoHttpEngineTCP()
Method Details
- bindServerSource
  
  protected static org.apache.pekko.stream.scaladsl.Source<Http.IncomingConnection,scala.concurrent.Future<Http.ServerBinding>> bindServerSource()
- clientConnectionFlow
  
  protected static org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> clientConnectionFlow(Http.ServerBinding serverBinding, org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)
- failsHandlerInputWhenHandlerOutputFails
  
  public static boolean failsHandlerInputWhenHandlerOutputFails()
- get
  
  public static org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,scala.concurrent.Future<Http.OutgoingConnection>> get(org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)
- canEqual
  
  public abstract static boolean canEqual(Object that)
- equals
  
  public abstract static boolean equals(Object that)
- productArity
  
  public abstract static int productArity()
- productElement
  
  public abstract static Object productElement(int n)
- productIterator
  
  public static scala.collection.Iterator<Object> productIterator()
- productPrefix
  
  public static String productPrefix()
- productElementName
  
  public static String productElementName(int n)
- productElementNames
  
  public static scala.collection.Iterator<String> productElementNames()