Package org.apache.pekko.http.scaladsl

Class GracefulTerminationSpec.TestSetup

java.lang.Object

org.apache.pekko.http.scaladsl.GracefulTerminationSpec.TestSetup

Enclosing class:

GracefulTerminationSpec

public class GracefulTerminationSpec.TestSetup
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ConnectionPoolSettings	basePoolSettings()
HttpsConnectionContext	clientConnectionContext()
AtomicInteger	counter()
HttpRequest	ensureServerDeliveredRequest(scala.concurrent.Future<HttpResponse> clientView)
scala.concurrent.Future<HttpResponse>	handler(HttpRequest req)
org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,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()
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

Constructor Details

TestSetup

public TestSetup(scala.Option<HttpResponse> overrideResponse)

Method Details

counter

public AtomicInteger counter()

idleTimeoutBaseForUniqueness

public int idleTimeoutBaseForUniqueness()

nextRequest

public HttpRequest nextRequest()

serverConnectionContext

public HttpsConnectionContext serverConnectionContext()

clientConnectionContext

public HttpsConnectionContext clientConnectionContext()

serverQueue

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

handler

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

ensureServerDeliveredRequest

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

reply

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

serverSettings

public ServerSettings serverSettings()

handlerFlow

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

serverBinding

public Http.ServerBinding serverBinding()

basePoolSettings

public ConnectionPoolSettings basePoolSettings()

makeRequest

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