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

Class EchoTestClientApp

java.lang.Object

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

public class EchoTestClientApp
extends java.lang.Object

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

Constructor Summary

Constructors

Constructor and Description
EchoTestClientApp()

Method Summary

Modifier and Type	Method and Description
protected static java.lang.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<java.lang.String>>>	echoClient()
static long	executionStart()
static void	main(java.lang.String[] args)
static scala.collection.immutable.List<Message>	messages()
static scala.concurrent.Future<scala.collection.immutable.Seq<java.lang.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 void	scala$App$$_args_$eq(java.lang.String[] x$1)
static java.lang.String[]	scala$App$$_args()
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<java.lang.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 Detail

EchoTestClientApp

public EchoTestClientApp()

Method Detail

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

echoClient

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

upgrade

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

res

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

args

protected static final java.lang.String[] args()

scala$App$$_args

public static java.lang.String[] scala$App$$_args()

scala$App$$_args_$eq

public static void scala$App$$_args_$eq(java.lang.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(java.lang.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)