Package 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 Object implements scala.App

  • Field Details

    • MODULE$

      public static final WSClientAutobahnTest$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • WSClientAutobahnTest$

      public WSClientAutobahnTest$()

  • Method Details

    • executionStart

      public final long executionStart()
      Specified by:
      executionStart in interface scala.App

    • system

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

    • Agent

      public String Agent()

    • Parallelism

      public int Parallelism()

    • getCaseCountUri

      public Uri getCaseCountUri()

    • runCaseUri

      public Uri runCaseUri(int caseIndex, String agent)

    • getCaseStatusUri

      public Uri getCaseStatusUri(int caseIndex, String agent)

    • getCaseInfoUri

      public Uri getCaseInfoUri(int caseIndex)

    • updateReportsUri

      public Uri updateReportsUri(String agent)

    • runCase

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

    • richRunCase

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

    • getCaseCount

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

    • getCaseInfo

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

    • getCaseStatus

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

    • updateReports

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

    • getCaseMap

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