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

Interface WebSocketClientSpec.ClientProbes

Enclosing class:
WebSocketClientSpec
public static interface WebSocketClientSpec.ClientProbes

  • Method Summary

    Modifier and Type
    Method
    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 Details

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