Class MockListener

java.lang.Object

kong.unirest.core.MockListener

All Implemented Interfaces:

WebSocket.Listener

public class MockListener
extends Object
implements WebSocket.Listener

A Mock WebSocket.Lister that records messages and has custom asserts.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	MockListener.Message

Field Summary

Fields

Modifier and Type	Field	Description
private String	closedMessage
private int	closedStatus
private List<MockListener.Message>	messagesReceived
private boolean	open
private ByteBuffer	ping
private ByteBuffer	pong

Constructor Summary

Constructors

Constructor	Description
MockListener()

Method Summary

Modifier and Type	Method	Description
void	assertIsClosed(int status, String message)
void	assertIsOpen()
void	assertPing(ByteBuffer message)	assert that a ping message was received.
void	assertPong(ByteBuffer message)	assert that a pong message was received.
void	assertReceivedMessage(Object message, boolean last)
CompletionStage<?>	onBinary(WebSocket webSocket, ByteBuffer data, boolean last)
CompletionStage<?>	onClose(WebSocket webSocket, int statusCode, String reason)
void	onError(WebSocket webSocket, Throwable error)
void	onOpen(WebSocket webSocket)
CompletionStage<?>	onPing(WebSocket webSocket, ByteBuffer message)
CompletionStage<?>	onPong(WebSocket webSocket, ByteBuffer message)
CompletionStage<?>	onText(WebSocket webSocket, CharSequence data, boolean last)

Methods inherited from class Object

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

Field Details

messagesReceived

private List<MockListener.Message> messagesReceived

ping

private ByteBuffer ping

pong

private ByteBuffer pong

open

private boolean open

closedStatus

private int closedStatus

closedMessage

private String closedMessage

Constructor Details

MockListener

public MockListener()

Method Details

onOpen

public void onOpen(WebSocket webSocket)

Specified by:

onOpen in interface WebSocket.Listener

onText

public CompletionStage<?> onText(WebSocket webSocket,
 CharSequence data,
 boolean last)

Specified by:

onText in interface WebSocket.Listener

onBinary

public CompletionStage<?> onBinary(WebSocket webSocket,
 ByteBuffer data,
 boolean last)

Specified by:

onBinary in interface WebSocket.Listener

onPing

public CompletionStage<?> onPing(WebSocket webSocket,
 ByteBuffer message)

Specified by:

onPing in interface WebSocket.Listener

onPong

public CompletionStage<?> onPong(WebSocket webSocket,
 ByteBuffer message)

Specified by:

onPong in interface WebSocket.Listener

onClose

public CompletionStage<?> onClose(WebSocket webSocket,
 int statusCode,
 String reason)

Specified by:

onClose in interface WebSocket.Listener

onError

public void onError(WebSocket webSocket,
 Throwable error)

Specified by:

onError in interface WebSocket.Listener

assertReceivedMessage

public void assertReceivedMessage(Object message,
 boolean last)

assertIsClosed

public void assertIsClosed(int status,
 String message)

assertPing

public void assertPing(ByteBuffer message)

assert that a ping message was received. Note that the onPing method will automatically send a pong to the WebSocket

Parameters:

message - the message

assertPong

public void assertPong(ByteBuffer message)

assert that a pong message was received. Note that the onPing method will automatically send a pong to the WebSocket

Parameters:

message - the message

assertIsOpen

public void assertIsOpen()