public class NewConnectionPoolSpec.TestSetup
extends java.lang.Object
Constructor and Description |
---|
TestSetup(ServerSettings serverSettings,
boolean autoAccept) |
Modifier and Type | Method and Description |
---|---|
void |
acceptIncomingConnection() |
scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> |
asyncTestServerHandler(int connNr) |
<T> scala.Tuple4<org.apache.pekko.stream.testkit.TestPublisher.Probe<scala.Tuple2<HttpRequest,T>>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<scala.Tuple2<scala.util.Try<HttpResponse>,T>>,org.reactivestreams.Subscription,Http.HostConnectionPool> |
cachedHostConnectionPool(int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.FiniteDuration idleTimeout,
scala.concurrent.duration.Duration maxConnectionLifetime,
ClientConnectionSettings ccSettings) |
<T> T |
condHolds(scala.concurrent.duration.FiniteDuration in,
scala.Function0<T> f)
Makes sure the given condition "f" holds in the timer period of "in".
|
int |
connNr(HttpResponse r) |
<T,Mat> scala.Tuple4<org.apache.pekko.stream.testkit.TestPublisher.Probe<scala.Tuple2<HttpRequest,T>>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<scala.Tuple2<scala.util.Try<HttpResponse>,T>>,org.reactivestreams.Subscription,Mat> |
flowTestBench(org.apache.pekko.stream.scaladsl.Flow<scala.Tuple2<HttpRequest,T>,scala.Tuple2<scala.util.Try<HttpResponse>,T>,Mat> poolFlow) |
java.util.concurrent.atomic.AtomicInteger |
incomingConnectionCounter() |
org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<Http.IncomingConnection> |
incomingConnections() |
org.reactivestreams.Subscription |
incomingConnectionsSub() |
org.apache.pekko.util.ByteString |
mapServerSideOutboundRawBytes(org.apache.pekko.util.ByteString bytes) |
java.lang.String |
requestUri(HttpResponse r) |
scala.collection.immutable.Seq<HttpHeader> |
responseHeaders(HttpRequest r,
int connNr) |
java.lang.String |
serverHostName() |
int |
serverPort() |
<T> scala.Tuple4<org.apache.pekko.stream.testkit.TestPublisher.Probe<scala.Tuple2<HttpRequest,T>>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<scala.Tuple2<scala.util.Try<HttpResponse>,T>>,org.reactivestreams.Subscription,org.apache.pekko.NotUsed> |
superPool(int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.FiniteDuration idleTimeout,
ClientConnectionSettings ccSettings) |
scala.Function1<HttpRequest,HttpResponse> |
testServerHandler(int connNr) |
public TestSetup(ServerSettings serverSettings, boolean autoAccept)
public scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> asyncTestServerHandler(int connNr)
public scala.Function1<HttpRequest,HttpResponse> testServerHandler(int connNr)
public scala.collection.immutable.Seq<HttpHeader> responseHeaders(HttpRequest r, int connNr)
public org.apache.pekko.util.ByteString mapServerSideOutboundRawBytes(org.apache.pekko.util.ByteString bytes)
public java.util.concurrent.atomic.AtomicInteger incomingConnectionCounter()
public org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<Http.IncomingConnection> incomingConnections()
public org.reactivestreams.Subscription incomingConnectionsSub()
public java.lang.String serverHostName()
public int serverPort()
public void acceptIncomingConnection()
public <T> scala.Tuple4<org.apache.pekko.stream.testkit.TestPublisher.Probe<scala.Tuple2<HttpRequest,T>>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<scala.Tuple2<scala.util.Try<HttpResponse>,T>>,org.reactivestreams.Subscription,Http.HostConnectionPool> cachedHostConnectionPool(int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.FiniteDuration idleTimeout, scala.concurrent.duration.Duration maxConnectionLifetime, ClientConnectionSettings ccSettings)
public <T> scala.Tuple4<org.apache.pekko.stream.testkit.TestPublisher.Probe<scala.Tuple2<HttpRequest,T>>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<scala.Tuple2<scala.util.Try<HttpResponse>,T>>,org.reactivestreams.Subscription,org.apache.pekko.NotUsed> superPool(int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.FiniteDuration idleTimeout, ClientConnectionSettings ccSettings)
public <T,Mat> scala.Tuple4<org.apache.pekko.stream.testkit.TestPublisher.Probe<scala.Tuple2<HttpRequest,T>>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<scala.Tuple2<scala.util.Try<HttpResponse>,T>>,org.reactivestreams.Subscription,Mat> flowTestBench(org.apache.pekko.stream.scaladsl.Flow<scala.Tuple2<HttpRequest,T>,scala.Tuple2<scala.util.Try<HttpResponse>,T>,Mat> poolFlow)
public int connNr(HttpResponse r)
public java.lang.String requestUri(HttpResponse r)
public <T> T condHolds(scala.concurrent.duration.FiniteDuration in, scala.Function0<T> f)
in
- (undocumented)f
- (undocumented)