GracefulTerminationSpec.TestSetup

public class GracefulTerminationSpec.TestSetup
extends java.lang.Object

Constructors
Constructor and Description
`TestSetup(scala.Option<HttpResponse> overrideResponse)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`ConnectionPoolSettings`	`basePoolSettings()`
`HttpsConnectionContext`	`clientConnectionContext()`
`java.util.concurrent.atomic.AtomicInteger`	`counter()`
`HttpRequest`	`ensureServerDeliveredRequest(scala.concurrent.Future<HttpResponse> clientView)`
`scala.concurrent.Future<HttpResponse>`	`handler(HttpRequest req)`
`org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,java.lang.Object>`	`handlerFlow()`
`int`	`idleTimeoutBaseForUniqueness()`
`scala.concurrent.Future<HttpResponse>`	`makeRequest(boolean ensureNewConnection)`
`HttpRequest`	`nextRequest()`
`void`	`reply(scala.Function1<HttpRequest,HttpResponse> fn)`
`Http.ServerBinding`	`serverBinding()`
`HttpsConnectionContext`	`serverConnectionContext()`
`java.util.concurrent.ArrayBlockingQueue<scala.Tuple2<HttpRequest,scala.concurrent.Promise<HttpResponse>>>`	`serverQueue()`
`ServerSettings`	`serverSettings()`

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

public TestSetup(scala.Option<HttpResponse> overrideResponse)

public java.util.concurrent.atomic.AtomicInteger counter()

public int idleTimeoutBaseForUniqueness()

public HttpsConnectionContext serverConnectionContext()

public HttpsConnectionContext clientConnectionContext()

public java.util.concurrent.ArrayBlockingQueue<scala.Tuple2<HttpRequest,scala.concurrent.Promise<HttpResponse>>> serverQueue()

public scala.concurrent.Future<HttpResponse> handler(HttpRequest req)

public HttpRequest ensureServerDeliveredRequest(scala.concurrent.Future<HttpResponse> clientView)

public void reply(scala.Function1<HttpRequest,HttpResponse> fn)

public ServerSettings serverSettings()

public org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,java.lang.Object> handlerFlow()

public Http.ServerBinding serverBinding()

public ConnectionPoolSettings basePoolSettings()

public scala.concurrent.Future<HttpResponse> makeRequest(boolean ensureNewConnection)

Class GracefulTerminationSpec.TestSetup