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

Interface WebSocketClientSpec.ClientProbes

Enclosing class:

WebSocketClientSpec

public static interface WebSocketClientSpec.ClientProbes

Method Summary

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()

Method Detail

clientImplementation

org.apache.pekko.stream.scaladsl.Flow<Message,Message,org.apache.pekko.NotUsed> clientImplementation()

messagesIn

org.apache.pekko.stream.testkit.TestSubscriber.Probe<Message> messagesIn()

messagesOut

org.apache.pekko.stream.testkit.TestPublisher.Probe<Message> messagesOut()