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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestSetup()

Method Summary

Modifier and Type	Method and Description
protected scala.concurrent.duration.FiniteDuration	closeTimeout()
BinaryMessage	expectBinaryMessage()
void	expectBinaryMessage(BinaryMessage message)
void	expectCloseCodeOnNetwork(int expectedCode)
<T> void	expectComplete(org.apache.pekko.stream.testkit.TestSubscriber.Probe<T> probe)
<T> java.lang.Throwable	expectError(org.apache.pekko.stream.testkit.TestSubscriber.Probe<T> probe)
scala.Tuple4<Protocol.Opcode,java.lang.Object,java.lang.Object,scala.Option<java.lang.Object>>	expectFrameHeaderOnNetwork()
scala.Option<java.lang.Object>	expectFrameHeaderOnNetwork(Protocol.Opcode opcode, long length, boolean fin) Returns the mask if any is available
void	expectFrameOnNetwork(Protocol.Opcode opcode, org.apache.pekko.util.ByteString data, boolean fin)
void	expectMaskedFrameOnNetwork(Protocol.Opcode opcode, org.apache.pekko.util.ByteString data, boolean fin)
Message	expectMessage()
void	expectMessage(Message message)
void	expectNetworkData(org.apache.pekko.util.ByteString data)
org.apache.pekko.util.ByteString	expectNetworkData(int bytes)
void	expectNoNetworkData()
void	expectProtocolErrorOnNetwork()
TextMessage	expectTextMessage()
void	expectTextMessage(TextMessage message)
org.apache.pekko.stream.scaladsl.Flow<Message,Message,org.apache.pekko.NotUsed>	messageHandler()
org.apache.pekko.stream.testkit.TestSubscriber.Probe<Message>	messageIn()
org.apache.pekko.stream.testkit.TestPublisher.Probe<Message>	messageOut()
org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString>	netIn()
ByteStringSinkProbe	netOut()
void	pushInput(org.apache.pekko.util.ByteString data)
void	pushMessage(Message msg)
protected abstract boolean	serverSide()
protected WebSocketSettings	websocketSettings()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestSetup

public TestSetup()

Method Detail

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> java.lang.Throwable expectError(org.apache.pekko.stream.testkit.TestSubscriber.Probe<T> probe)

expectFrameHeaderOnNetwork

public scala.Option<java.lang.Object> expectFrameHeaderOnNetwork(Protocol.Opcode opcode,
                                                                 long length,
                                                                 boolean fin)

Returns the mask if any is available

expectFrameHeaderOnNetwork

public scala.Tuple4<Protocol.Opcode,java.lang.Object,java.lang.Object,scala.Option<java.lang.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()