org.apache.pekko.http.scaladsl

Class ClientServerSpecBase.TestSetup

java.lang.Object

org.apache.pekko.http.scaladsl.ClientServerSpecBase.TestSetup

Enclosing class:

ClientServerSpecBase

public class ClientServerSpecBase.TestSetup
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestSetup()

Method Summary

Modifier and Type	Method and Description
scala.Tuple2<org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<HttpRequest>,org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<HttpResponse>>	acceptConnection()
scala.concurrent.Future<Http.ServerBinding>	binding()
java.lang.String	configOverrides()
org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<Http.IncomingConnection>	connSource()
org.reactivestreams.Subscription	connSourceSub()
java.lang.String	hostname()
java.net.Socket	openClientSocket()
scala.Tuple2<org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<HttpRequest>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<HttpResponse>>	openNewClientConnection(ClientConnectionSettings settings)
int	port()
scala.Tuple2<java.lang.String,java.io.BufferedReader>	readAll(java.net.Socket socket, java.io.BufferedReader reader)
java.io.BufferedWriter	write(java.net.Socket socket, java.lang.String data)

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSetup

public TestSetup()

Method Detail

acceptConnection

public scala.Tuple2<org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<HttpRequest>,org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<HttpResponse>> acceptConnection()

binding

public scala.concurrent.Future<Http.ServerBinding> binding()

configOverrides

public java.lang.String configOverrides()

connSource

public org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<Http.IncomingConnection> connSource()

connSourceSub

public org.reactivestreams.Subscription connSourceSub()

hostname

public java.lang.String hostname()

openClientSocket

public java.net.Socket openClientSocket()

openNewClientConnection

public scala.Tuple2<org.apache.pekko.stream.testkit.TestPublisher.ManualProbe<HttpRequest>,org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<HttpResponse>> openNewClientConnection(ClientConnectionSettings settings)

port

public int port()

readAll

public scala.Tuple2<java.lang.String,java.io.BufferedReader> readAll(java.net.Socket socket,
                                                                     java.io.BufferedReader reader)

write

public java.io.BufferedWriter write(java.net.Socket socket,
                                    java.lang.String data)