Package 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 Object

  • Constructor Details

    • HttpServerTestSetupBase

      public HttpServerTestSetupBase()

  • Method Details

    • 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(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(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 String wipeDate(String string)