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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestSetup(int maxResponseContentLength, java.lang.String config)

Method Summary

Modifier and Type	Method and Description
void	closeNetworkInput()
HttpResponse	expectResponse()
org.scalatest.compatible.Assertion	expectWireData(java.lang.String s)
org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<org.apache.pekko.util.ByteString>	netIn()
org.apache.pekko.stream.testkit.StreamTestKit.PublisherProbeSubscription<org.apache.pekko.util.ByteString>	netInSub()
org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<org.apache.pekko.util.ByteString>	netOut()
org.reactivestreams.Subscription	netOutSub()
org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<HttpRequest>	requests()
org.apache.pekko.stream.testkit.StreamTestKit.PublisherProbeSubscription<HttpRequest>	requestsSub()
org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<HttpResponse>	responses()
org.reactivestreams.Subscription	responsesSub()
org.scalatest.compatible.Assertion	sendStandardRequest()
void	sendWireData(org.apache.pekko.util.ByteString data)
void	sendWireData(java.lang.String data)
ClientConnectionSettings	settings()
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

TestSetup

public TestSetup(int maxResponseContentLength,
                 java.lang.String config)

Method Detail

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 java.lang.String wipeDate(java.lang.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(java.lang.String data)

sendWireData

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

expectWireData

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

closeNetworkInput

public void closeNetworkInput()

sendStandardRequest

public org.scalatest.compatible.Assertion sendStandardRequest()

expectResponse

public HttpResponse expectResponse()