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

Class HostConnectionPoolSpec.TopLevelApiClientServerImplementation

java.lang.Object

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

All Implemented Interfaces:

HostConnectionPoolSpec.ClientServerImplementation

Direct Known Subclasses:

HostConnectionPoolSpec.PekkoHttpEngineTCP$, HostConnectionPoolSpec.PekkoHttpEngineTLS$

Enclosing class:

HostConnectionPoolSpec

public abstract class HostConnectionPoolSpec.TopLevelApiClientServerImplementation
extends java.lang.Object
implements HostConnectionPoolSpec.ClientServerImplementation

Constructor Summary

Constructors

Constructor and Description
TopLevelApiClientServerImplementation()

Method Summary

Modifier and Type	Method and Description
protected abstract org.apache.pekko.stream.scaladsl.Source<Http.IncomingConnection,scala.concurrent.Future<Http.ServerBinding>>	bindServerSource()
protected abstract org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>>	clientConnectionFlow(Http.ServerBinding serverBinding, org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)
boolean	failsHandlerInputWhenHandlerOutputFails() Specifies if the transport implementation will fail the handler request input side if an error is encountered at the response output side.
org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,scala.concurrent.Future<Http.OutgoingConnection>>	get(org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch) Returns a client / server implementation that include the kill switch flow in the middle

Methods inherited from class java.lang.Object

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

Constructor Detail

TopLevelApiClientServerImplementation

public TopLevelApiClientServerImplementation()

Method Detail

bindServerSource

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

clientConnectionFlow

protected abstract 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 boolean failsHandlerInputWhenHandlerOutputFails()

Description copied from interface: HostConnectionPoolSpec.ClientServerImplementation

Specifies if the transport implementation will fail the handler request input side if an error is encountered at the response output side.

I haven't decided yet what the right behavior should be.

Specified by:

failsHandlerInputWhenHandlerOutputFails in interface HostConnectionPoolSpec.ClientServerImplementation

Returns:

(undocumented)

get

public org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,scala.concurrent.Future<Http.OutgoingConnection>> get(org.apache.pekko.stream.SharedKillSwitch connectionKillSwitch)

Description copied from interface: HostConnectionPoolSpec.ClientServerImplementation

Returns a client / server implementation that include the kill switch flow in the middle

Specified by:

get in interface HostConnectionPoolSpec.ClientServerImplementation