public static interface WebSocketClientSpec.ClientProbes
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.scaladsl.Flow<Message,Message,org.apache.pekko.NotUsed> |
clientImplementation() |
org.apache.pekko.stream.testkit.TestSubscriber.Probe<Message> |
messagesIn() |
org.apache.pekko.stream.testkit.TestPublisher.Probe<Message> |
messagesOut() |
org.apache.pekko.stream.scaladsl.Flow<Message,Message,org.apache.pekko.NotUsed> clientImplementation()
org.apache.pekko.stream.testkit.TestSubscriber.Probe<Message> messagesIn()
org.apache.pekko.stream.testkit.TestPublisher.Probe<Message> messagesOut()