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 java.lang.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 and Description
static EchoTestClientApp$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
EchoTestClientApp$()

Method Summary

Modifier and Type	Method and 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<java.lang.String>>>	echoClient()
long	executionStart()
scala.collection.immutable.List<Message>	messages()
scala.concurrent.Future<scala.collection.immutable.Seq<java.lang.String>>	res()
org.apache.pekko.stream.scaladsl.Sink<Message,scala.concurrent.Future<scala.collection.immutable.Seq<java.lang.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

$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 EchoTestClientApp$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

EchoTestClientApp$

public EchoTestClientApp$()

Method Detail

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<java.lang.String>>> sink()

echoClient

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

upgrade

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

res

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