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

Class EchoTestClientApp$

java.lang.Object
org.apache.pekko.http.impl.engine.ws.EchoTestClientApp$
All Implemented Interfaces:
scala.App, scala.DelayedInit
public class EchoTestClientApp$ extends Object implements scala.App
An example App that runs a quick test against the websocket server at wss://echo.websocket.org

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    EchoTestClientApp$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.stream.scaladsl.Source<scala.runtime.Nothing$,org.apache.pekko.NotUsed>
    delayedCompletion(scala.concurrent.duration.FiniteDuration delay)
     
    org.apache.pekko.stream.scaladsl.Flow<Message,Message,scala.concurrent.Future<scala.collection.immutable.Seq<String>>>
    echoClient()
     
    final long
    executionStart()
     
    scala.collection.immutable.List<Message>
    messages()
     
    scala.concurrent.Future<scala.collection.immutable.Seq<String>>
    res()
     
    org.apache.pekko.stream.scaladsl.Sink<Message,scala.concurrent.Future<scala.collection.immutable.Seq<String>>>
    sink()
     
    org.apache.pekko.stream.scaladsl.Source<Message,org.apache.pekko.NotUsed>
    source()
     
    org.apache.pekko.actor.ActorSystem
    system()
     
    scala.concurrent.Future<WebSocketUpgradeResponse>
    upgrade()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface scala.App

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

  • Field Details

    • MODULE$

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

  • Constructor Details

    • EchoTestClientApp$

      public EchoTestClientApp$()

  • Method Details

    • executionStart

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

    • system

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

    • delayedCompletion

      public org.apache.pekko.stream.scaladsl.Source<scala.runtime.Nothing$,org.apache.pekko.NotUsed> delayedCompletion(scala.concurrent.duration.FiniteDuration delay)

    • messages

      public scala.collection.immutable.List<Message> messages()

    • source

      public org.apache.pekko.stream.scaladsl.Source<Message,org.apache.pekko.NotUsed> source()

    • sink

      public org.apache.pekko.stream.scaladsl.Sink<Message,scala.concurrent.Future<scala.collection.immutable.Seq<String>>> sink()

    • echoClient

      public org.apache.pekko.stream.scaladsl.Flow<Message,Message,scala.concurrent.Future<scala.collection.immutable.Seq<String>>> echoClient()

    • upgrade

      public scala.concurrent.Future<WebSocketUpgradeResponse> upgrade()

    • res

      public scala.concurrent.Future<scala.collection.immutable.Seq<String>> res()