public class EchoTestClientApp$
extends java.lang.Object
implements scala.App
Modifier and Type | Field and Description |
---|---|
static EchoTestClientApp$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
EchoTestClientApp$() |
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() |
public static final EchoTestClientApp$ MODULE$
public final long executionStart()
executionStart
in interface scala.App
public org.apache.pekko.actor.ActorSystem system()
public org.apache.pekko.stream.scaladsl.Source<scala.runtime.Nothing$,org.apache.pekko.NotUsed> delayedCompletion(scala.concurrent.duration.FiniteDuration delay)
public scala.collection.immutable.List<Message> messages()
public org.apache.pekko.stream.scaladsl.Source<Message,org.apache.pekko.NotUsed> source()
public org.apache.pekko.stream.scaladsl.Sink<Message,scala.concurrent.Future<scala.collection.immutable.Seq<java.lang.String>>> sink()
public org.apache.pekko.stream.scaladsl.Flow<Message,Message,scala.concurrent.Future<scala.collection.immutable.Seq<java.lang.String>>> echoClient()
public scala.concurrent.Future<WebSocketUpgradeResponse> upgrade()
public scala.concurrent.Future<scala.collection.immutable.Seq<java.lang.String>> res()