Package org.apache.pekko.http.impl.engine.client

Class LowLevelOutgoingConnectionSpec.TestSetup

java.lang.Object
org.apache.pekko.http.impl.engine.client.LowLevelOutgoingConnectionSpec.TestSetup
Enclosing class:
LowLevelOutgoingConnectionSpec
public class LowLevelOutgoingConnectionSpec.TestSetup extends Object

  • Constructor Details

    • TestSetup

      public TestSetup(int maxResponseContentLength, String config)

  • Method Details

    • requests

      public org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<HttpRequest> requests()

    • responses

      public org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<HttpResponse> responses()

    • settings

      public ClientConnectionSettings settings()

    • netOut

      public org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<org.apache.pekko.util.ByteString> netOut()

    • netIn

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

    • wipeDate

      public String wipeDate(String string)

    • netInSub

      public org.apache.pekko.stream.testkit.StreamTestKit.PublisherProbeSubscription<org.apache.pekko.util.ByteString> netInSub()

    • netOutSub

      public org.reactivestreams.Subscription netOutSub()

    • requestsSub

      public org.apache.pekko.stream.testkit.StreamTestKit.PublisherProbeSubscription<HttpRequest> requestsSub()

    • responsesSub

      public org.reactivestreams.Subscription responsesSub()

    • sendWireData

      public void sendWireData(String data)

    • sendWireData

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

    • expectWireData

      public org.scalatest.compatible.Assertion expectWireData(String s)

    • closeNetworkInput

      public void closeNetworkInput()

    • sendStandardRequest

      public org.scalatest.compatible.Assertion sendStandardRequest()

    • expectResponse

      public HttpResponse expectResponse()