Class MockWebSocket

java.lang.Object

kong.unirest.core.MockWebSocket

All Implemented Interfaces:

WebSocket

public class MockWebSocket
extends Object
implements WebSocket

A Mock of a websocket that sends messages directly to a single listener on the other side

Nested Class Summary

Nested classes/interfaces inherited from interface WebSocket

WebSocket.Builder, WebSocket.Listener

Field Summary

Fields

Modifier and Type	Field	Description
private SocketSet	remoteSocketSet

Fields inherited from interface WebSocket

NORMAL_CLOSURE

Constructor Summary

Constructors

Constructor	Description
MockWebSocket()

Method Summary

Modifier and Type	Method	Description
void	abort()
String	getSubprotocol()
void	init(SocketSet otherSide)
boolean	isInputClosed()
boolean	isOutputClosed()
void	request(long n)
CompletableFuture<WebSocket>	sendBinary(ByteBuffer data, boolean last)
CompletableFuture<WebSocket>	sendClose(int statusCode, String reason)
CompletableFuture<WebSocket>	sendPing(ByteBuffer message)
CompletableFuture<WebSocket>	sendPong(ByteBuffer message)
CompletableFuture<WebSocket>	sendText(CharSequence data, boolean last)
private CompletableFuture<WebSocket>	sendToOtherSide(BiConsumer<WebSocket, WebSocket.Listener> consumer)

Methods inherited from class Object

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

Field Details

remoteSocketSet

private SocketSet remoteSocketSet

Constructor Details

MockWebSocket

public MockWebSocket()

Method Details

sendToOtherSide

private CompletableFuture<WebSocket> sendToOtherSide(BiConsumer<WebSocket, WebSocket.Listener> consumer)

sendText

public CompletableFuture<WebSocket> sendText(CharSequence data,
 boolean last)

Specified by:

sendText in interface WebSocket

sendBinary

public CompletableFuture<WebSocket> sendBinary(ByteBuffer data,
 boolean last)

Specified by:

sendBinary in interface WebSocket

sendPing

public CompletableFuture<WebSocket> sendPing(ByteBuffer message)

Specified by:

sendPing in interface WebSocket

sendPong

public CompletableFuture<WebSocket> sendPong(ByteBuffer message)

Specified by:

sendPong in interface WebSocket

sendClose

public CompletableFuture<WebSocket> sendClose(int statusCode,
 String reason)

Specified by:

sendClose in interface WebSocket

request

public void request(long n)

Specified by:

request in interface WebSocket

getSubprotocol

public String getSubprotocol()

Specified by:

getSubprotocol in interface WebSocket

isOutputClosed

public boolean isOutputClosed()

Specified by:

isOutputClosed in interface WebSocket

isInputClosed

public boolean isInputClosed()

Specified by:

isInputClosed in interface WebSocket

abort

public void abort()

Specified by:

abort in interface WebSocket

init

public void init(SocketSet otherSide)