ClientServerSpecBase.TestSetup

java.lang.Object

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

Enclosing class:: ClientServerSpecBase

public class ClientServerSpecBase.TestSetup extends Object

Constructor Summary

Constructors

Constructor

Description

TestSetup()
Method Summary

Modifier and Type

Method

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()

String

configOverrides()

org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<Http.IncomingConnection>

connSource()

org.reactivestreams.Subscription

connSourceSub()

String

hostname()

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<String,BufferedReader>

readAll(Socket socket, BufferedReader reader)

BufferedWriter

write(Socket socket, String data)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- TestSetup
  
  public TestSetup()
Method Details
- 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 String configOverrides()
- connSource
  
  public org.apache.pekko.stream.testkit.TestSubscriber.ManualProbe<Http.IncomingConnection> connSource()
- connSourceSub
  
  public org.reactivestreams.Subscription connSourceSub()
- hostname
  
  public String hostname()
- openClientSocket
  
  public 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<String,BufferedReader> readAll(Socket socket, BufferedReader reader)
- write
  
  public BufferedWriter write(Socket socket, String data)