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

Class EchoTestClientApp

java.lang.Object

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

public class EchoTestClientApp
extends Object

An example App that runs a quick test against the websocket server at wss://echo.websocket.org

Constructor Summary

Constructors

Constructor	Description
EchoTestClientApp()

Method Summary

Modifier and Type	Method	Description
protected static final String[]	args()
static org.apache.pekko.stream.scaladsl.Source<scala.runtime.Nothing$,org.apache.pekko.NotUsed>	delayedCompletion(scala.concurrent.duration.FiniteDuration delay)
static void	delayedInit(scala.Function0<scala.runtime.BoxedUnit> body)
static org.apache.pekko.stream.scaladsl.Flow<Message,Message,scala.concurrent.Future<scala.collection.immutable.Seq<String>>>	echoClient()
static final long	executionStart()
static final void	main(String[] args)
static scala.collection.immutable.List<Message>	messages()
static scala.concurrent.Future<scala.collection.immutable.Seq<String>>	res()
protected abstract static void	scala$App$_setter_$executionStart_$eq(long x$1)
protected abstract static void	scala$App$_setter_$scala$App$$initCode_$eq(scala.collection.mutable.ListBuffer<scala.Function0<scala.runtime.BoxedUnit>> x$1)
static String[]	scala$App$$_args()
static void	scala$App$$_args_$eq(String[] x$1)
static scala.collection.mutable.ListBuffer<scala.Function0<scala.runtime.BoxedUnit>>	scala$App$$initCode()
static org.apache.pekko.stream.scaladsl.Sink<Message,scala.concurrent.Future<scala.collection.immutable.Seq<String>>>	sink()
static org.apache.pekko.stream.scaladsl.Source<Message,org.apache.pekko.NotUsed>	source()
static org.apache.pekko.actor.ActorSystem	system()
static scala.concurrent.Future<WebSocketUpgradeResponse>	upgrade()

Methods inherited from class java.lang.Object

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

Constructor Details

EchoTestClientApp

public EchoTestClientApp()

Method Details

executionStart

public static final long executionStart()

system

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

delayedCompletion

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

messages

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

source

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

sink

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

echoClient

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

upgrade

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

res

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

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)