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

Class WSClientAutobahnTest

java.lang.Object
org.apache.pekko.http.impl.engine.ws.WSClientAutobahnTest
public class WSClientAutobahnTest extends Object

  • Constructor Details

    • WSClientAutobahnTest

      public WSClientAutobahnTest()

  • Method Details

    • executionStart

      public static final long executionStart()

    • system

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

    • Agent

      public static String Agent()

    • Parallelism

      public static int Parallelism()

    • getCaseCountUri

      public static Uri getCaseCountUri()

    • runCaseUri

      public static Uri runCaseUri(int caseIndex, String agent)

    • getCaseStatusUri

      public static Uri getCaseStatusUri(int caseIndex, String agent)

    • getCaseInfoUri

      public static Uri getCaseInfoUri(int caseIndex)

    • updateReportsUri

      public static Uri updateReportsUri(String agent)

    • runCase

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

    • richRunCase

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

    • getCaseCount

      public static scala.concurrent.Future<Object> getCaseCount()

    • getCaseInfo

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

    • getCaseStatus

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

    • updateReports

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

    • getCaseMap

      public static scala.concurrent.Future<scala.collection.immutable.Map<String,WSClientAutobahnTest.IndexedCaseInfo>> getCaseMap()
      Map from textual case ID (like 1.1.1) to IndexedCaseInfo
      Returns:

    • echo

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

    • completion

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

    • updateReportsAndShutdown

      public static void updateReportsAndShutdown()

    • runWs

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

    • completionSignal

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

    • runToSingleText

      public static scala.concurrent.Future<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 static <T> scala.concurrent.Future<T> runToSingleJsonValue(Uri uri, spray.json.JsonReader<T> evidence$1)

    • args

      protected static final String[] args()

    • scala$App$$_args

      public static String[] scala$App$$_args()

    • scala$App$$_args_$eq

      public static void scala$App$$_args_$eq(String[] x$1)

    • scala$App$$initCode

      public static scala.collection.mutable.ListBuffer<scala.Function0<scala.runtime.BoxedUnit>> scala$App$$initCode()

    • delayedInit

      public static void delayedInit(scala.Function0<scala.runtime.BoxedUnit> body)

    • main

      public static final void main(String[] args)

    • scala$App$_setter_$executionStart_$eq

      protected abstract static void scala$App$_setter_$executionStart_$eq(long x$1)

    • scala$App$_setter_$scala$App$$initCode_$eq

      protected abstract static void scala$App$_setter_$scala$App$$initCode_$eq(scala.collection.mutable.ListBuffer<scala.Function0<scala.runtime.BoxedUnit>> x$1)