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

Class NewConnectionPoolSpec.ClientTransportTestSetup

java.lang.Object

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

Enclosing class:

NewConnectionPoolSpec

public abstract class NewConnectionPoolSpec.ClientTransportTestSetup
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	NewConnectionPoolSpec.ClientTransportTestSetup.CustomTransport

Constructor Summary

Constructors

Constructor and Description
ClientTransportTestSetup()

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.FiniteDuration	CustomIdleTimeout()
java.lang.String	host()
abstract scala.concurrent.Future<HttpResponse>	issueRequest(HttpRequest request, ConnectionPoolSettings settings)
ConnectionPoolSettings	poolSettings()
int	port()
HttpResponse	response()
scala.concurrent.Future<HttpResponse>	responseFuture()
ClientConnectionSettings	settings()
NewConnectionPoolSpec.ClientTransportTestSetup.CustomTransport	transport()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientTransportTestSetup

public ClientTransportTestSetup()

Method Detail

CustomIdleTimeout

public scala.concurrent.duration.FiniteDuration CustomIdleTimeout()

host

public java.lang.String host()

issueRequest

public abstract scala.concurrent.Future<HttpResponse> issueRequest(HttpRequest request,
                                                                   ConnectionPoolSettings settings)

poolSettings

public ConnectionPoolSettings poolSettings()

port

public int port()

response

public HttpResponse response()

responseFuture

public scala.concurrent.Future<HttpResponse> responseFuture()

settings

public ClientConnectionSettings settings()

transport

public NewConnectionPoolSpec.ClientTransportTestSetup.CustomTransport transport()