org.apache.pekko.http.impl.engine.server

Class HttpServerTestSetupBase

java.lang.Object

org.apache.pekko.http.impl.engine.server.HttpServerTestSetupBase

Direct Known Subclasses:

HttpServerSpec.TestSetup, HttpServerWithExplicitSchedulerSpec.TestSetup, WebSocketServerSpec.TestSetup

public abstract class HttpServerTestSetupBase
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
HttpServerTestSetupBase()

Method Summary

Modifier and Type	Method and Description
void	closeNetworkInput()
void	expectNetworkClose()
void	expectNoRequest(scala.concurrent.duration.FiniteDuration max)
HttpRequest	expectRequest()
void	expectResponseWithWipedDate(java.lang.String expected)
void	expectSubscribe()
void	expectSubscribeAndNetworkClose()
abstract org.apache.pekko.stream.Materializer	materializer()
org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,HttpRequest,org.apache.pekko.NotUsed>	modifyServer(org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,HttpRequest,org.apache.pekko.NotUsed> server)
org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString>	netIn()
ByteStringSinkProbe	netOut()
org.apache.pekko.stream.testkit.TestSubscriber.Probe<HttpRequest>	requests()
org.apache.pekko.stream.testkit.TestPublisher.Probe<HttpResponse>	responses()
void	send(org.apache.pekko.util.ByteString data)
void	send(java.lang.String string)
ServerSettings	settings()
void	shutdownBlueprint()
void	simpleResponse()
abstract org.apache.pekko.actor.ActorSystem	system()
java.lang.String	wipeDate(java.lang.String string)

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpServerTestSetupBase

public HttpServerTestSetupBase()

Method Detail

closeNetworkInput

public void closeNetworkInput()

expectNetworkClose

public void expectNetworkClose()

expectNoRequest

public void expectNoRequest(scala.concurrent.duration.FiniteDuration max)

expectRequest

public HttpRequest expectRequest()

expectResponseWithWipedDate

public void expectResponseWithWipedDate(java.lang.String expected)

expectSubscribe

public void expectSubscribe()

expectSubscribeAndNetworkClose

public void expectSubscribeAndNetworkClose()

materializer

public abstract org.apache.pekko.stream.Materializer materializer()

modifyServer

public org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,HttpRequest,org.apache.pekko.NotUsed> modifyServer(org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,HttpRequest,org.apache.pekko.NotUsed> server)

netIn

public org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString> netIn()

netOut

public ByteStringSinkProbe netOut()

requests

public org.apache.pekko.stream.testkit.TestSubscriber.Probe<HttpRequest> requests()

responses

public org.apache.pekko.stream.testkit.TestPublisher.Probe<HttpResponse> responses()

send

public void send(org.apache.pekko.util.ByteString data)

send

public void send(java.lang.String string)

settings

public ServerSettings settings()

shutdownBlueprint

public void shutdownBlueprint()

simpleResponse

public void simpleResponse()

system

public abstract org.apache.pekko.actor.ActorSystem system()

wipeDate

public java.lang.String wipeDate(java.lang.String string)