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

Class MessageSpec.TestSetup

java.lang.Object
org.apache.pekko.http.impl.engine.ws.MessageSpec.TestSetup
Direct Known Subclasses:
MessageSpec.ClientTestSetup, MessageSpec.ServerTestSetup
Enclosing class:
MessageSpec
public abstract class MessageSpec.TestSetup extends Object

  • Constructor Details

    • TestSetup

      public TestSetup()

  • Method Details

    • closeTimeout

      protected scala.concurrent.duration.FiniteDuration closeTimeout()

    • expectBinaryMessage

      public void expectBinaryMessage(BinaryMessage message)

    • expectBinaryMessage

      public BinaryMessage expectBinaryMessage()

    • expectCloseCodeOnNetwork

      public void expectCloseCodeOnNetwork(int expectedCode)

    • expectComplete

      public <T> void expectComplete(org.apache.pekko.stream.testkit.TestSubscriber.Probe<T> probe)

    • expectError

      public <T> Throwable expectError(org.apache.pekko.stream.testkit.TestSubscriber.Probe<T> probe)

    • expectFrameHeaderOnNetwork

      public scala.Option<Object> expectFrameHeaderOnNetwork(Protocol.Opcode opcode, long length, boolean fin)
      Returns the mask if any is available

    • expectFrameHeaderOnNetwork

      public scala.Tuple4<Protocol.Opcode,Object,Object,scala.Option<Object>> expectFrameHeaderOnNetwork()

    • expectFrameOnNetwork

      public void expectFrameOnNetwork(Protocol.Opcode opcode, org.apache.pekko.util.ByteString data, boolean fin)

    • expectMaskedFrameOnNetwork

      public void expectMaskedFrameOnNetwork(Protocol.Opcode opcode, org.apache.pekko.util.ByteString data, boolean fin)

    • expectMessage

      public void expectMessage(Message message)

    • expectMessage

      public Message expectMessage()

    • expectNetworkData

      public void expectNetworkData(org.apache.pekko.util.ByteString data)

    • expectNetworkData

      public final org.apache.pekko.util.ByteString expectNetworkData(int bytes)

    • expectNoNetworkData

      public void expectNoNetworkData()

    • expectProtocolErrorOnNetwork

      public void expectProtocolErrorOnNetwork()

    • expectTextMessage

      public void expectTextMessage(TextMessage message)

    • expectTextMessage

      public TextMessage expectTextMessage()

    • messageHandler

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

    • messageIn

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

    • messageOut

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

    • netIn

      public org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString> netIn()

    • netOut

      public ByteStringSinkProbe netOut()

    • pushInput

      public void pushInput(org.apache.pekko.util.ByteString data)

    • pushMessage

      public void pushMessage(Message msg)

    • serverSide

      protected abstract boolean serverSide()

    • websocketSettings

      protected WebSocketSettings websocketSettings()