org.apache.pekko.http.impl.engine.ws

Class WSClientAutobahnTest$

java.lang.Object

org.apache.pekko.http.impl.engine.ws.WSClientAutobahnTest$

All Implemented Interfaces:

scala.App, scala.DelayedInit

public class WSClientAutobahnTest$
extends java.lang.Object
implements scala.App

Field Summary

Fields

Modifier and Type	Field and Description
static WSClientAutobahnTest$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
WSClientAutobahnTest$()

Method Summary

Modifier and Type	Method and Description
java.lang.String	Agent()
<T> scala.Function1<scala.util.Try<T>,scala.runtime.BoxedUnit>	completion()
<T> org.apache.pekko.stream.scaladsl.Flow<T,T,scala.concurrent.Future<org.apache.pekko.Done>>	completionSignal()
org.apache.pekko.stream.scaladsl.Flow<Message,Message,scala.concurrent.Future<org.apache.pekko.Done>>	echo()
long	executionStart()
scala.concurrent.Future<java.lang.Object>	getCaseCount()
Uri	getCaseCountUri()
scala.concurrent.Future<WSClientAutobahnTest.IndexedCaseInfo>	getCaseInfo(int caseId)
Uri	getCaseInfoUri(int caseIndex)
scala.concurrent.Future<scala.collection.immutable.Map<java.lang.String,WSClientAutobahnTest.IndexedCaseInfo>>	getCaseMap() Map from textual case ID (like 1.1.1) to IndexedCaseInfo
scala.concurrent.Future<WSClientAutobahnTest.CaseStatus>	getCaseStatus(int caseId, java.lang.String agent)
Uri	getCaseStatusUri(int caseIndex, java.lang.String agent)
int	Parallelism()
scala.concurrent.Future<WSClientAutobahnTest.CaseResult>	richRunCase(int caseIndex, java.lang.String agent)
scala.concurrent.Future<WSClientAutobahnTest.CaseStatus>	runCase(int caseIndex, java.lang.String agent)
Uri	runCaseUri(int caseIndex, java.lang.String agent)
<T> scala.concurrent.Future<T>	runToSingleJsonValue(Uri uri, spray.json.JsonReader<T> evidence$1)
scala.concurrent.Future<java.lang.String>	runToSingleText(Uri uri) The autobahn tests define a weird API where every request must be a WebSocket request and they will send a single websocket message with the result.
<T> T	runWs(Uri uri, org.apache.pekko.stream.scaladsl.Flow<Message,Message,T> clientFlow)
org.apache.pekko.actor.ActorSystem	system()
scala.concurrent.Future<scala.runtime.BoxedUnit>	updateReports(java.lang.String agent)
void	updateReportsAndShutdown()
Uri	updateReportsUri(java.lang.String agent)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.App

$init$, args, delayedInit, main, scala$App$_setter_$executionStart_$eq, scala$App$_setter_$scala$App$$initCode_$eq, scala$App$$_args_$eq, scala$App$$_args, scala$App$$initCode

Field Detail

MODULE$

public static final WSClientAutobahnTest$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

WSClientAutobahnTest$

public WSClientAutobahnTest$()

Method Detail

executionStart

public final long executionStart()

Specified by:

executionStart in interface scala.App

system

public org.apache.pekko.actor.ActorSystem system()

Agent

public java.lang.String Agent()

Parallelism

public int Parallelism()

getCaseCountUri

public Uri getCaseCountUri()

runCaseUri

public Uri runCaseUri(int caseIndex,
                      java.lang.String agent)

getCaseStatusUri

public Uri getCaseStatusUri(int caseIndex,
                            java.lang.String agent)

getCaseInfoUri

public Uri getCaseInfoUri(int caseIndex)

updateReportsUri

public Uri updateReportsUri(java.lang.String agent)

runCase

public scala.concurrent.Future<WSClientAutobahnTest.CaseStatus> runCase(int caseIndex,
                                                                        java.lang.String agent)

richRunCase

public scala.concurrent.Future<WSClientAutobahnTest.CaseResult> richRunCase(int caseIndex,
                                                                            java.lang.String agent)

getCaseCount

public scala.concurrent.Future<java.lang.Object> getCaseCount()

getCaseInfo

public scala.concurrent.Future<WSClientAutobahnTest.IndexedCaseInfo> getCaseInfo(int caseId)

getCaseStatus

public scala.concurrent.Future<WSClientAutobahnTest.CaseStatus> getCaseStatus(int caseId,
                                                                              java.lang.String agent)

updateReports

public scala.concurrent.Future<scala.runtime.BoxedUnit> updateReports(java.lang.String agent)

getCaseMap

public scala.concurrent.Future<scala.collection.immutable.Map<java.lang.String,WSClientAutobahnTest.IndexedCaseInfo>> getCaseMap()

Map from textual case ID (like 1.1.1) to IndexedCaseInfo

Returns:

echo

public org.apache.pekko.stream.scaladsl.Flow<Message,Message,scala.concurrent.Future<org.apache.pekko.Done>> echo()

completion

public <T> scala.Function1<scala.util.Try<T>,scala.runtime.BoxedUnit> completion()

updateReportsAndShutdown

public void updateReportsAndShutdown()

runWs

public <T> T runWs(Uri uri,
                   org.apache.pekko.stream.scaladsl.Flow<Message,Message,T> clientFlow)

completionSignal

public <T> org.apache.pekko.stream.scaladsl.Flow<T,T,scala.concurrent.Future<org.apache.pekko.Done>> completionSignal()

runToSingleText

public scala.concurrent.Future<java.lang.String> runToSingleText(Uri uri)

The autobahn tests define a weird API where every request must be a WebSocket request and they will send a single websocket message with the result. WebSocket everywhere? Strange, but somewhat consistent.

Parameters:

uri - (undocumented)

Returns:

(undocumented)

runToSingleJsonValue

public <T> scala.concurrent.Future<T> runToSingleJsonValue(Uri uri,
                                                           spray.json.JsonReader<T> evidence$1)