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

Class HostConnectionPoolSpec.PassThrough$

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

HostConnectionPoolSpec

public class HostConnectionPoolSpec.PassThrough$
extends java.lang.Object
implements HostConnectionPoolSpec.ClientServerImplementation, scala.Product, java.io.Serializable

Transport that just passes through requests / responses

See Also:

Serialized Form

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
PassThrough$()

Method Summary

Modifier and Type	Method and Description
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
org.apache.pekko.http.impl.engine.client.HostConnectionPoolSpec.PassThrough$.PassThroughTransport$	PassThroughTransport()

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.PassThrough$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

PassThrough$

public PassThrough$()

Method Detail

PassThroughTransport

public org.apache.pekko.http.impl.engine.client.HostConnectionPoolSpec.PassThrough$.PassThroughTransport$ PassThroughTransport()

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