Package kong.unirest.core
Class MockListener
- java.lang.Object
-
- kong.unirest.core.MockListener
-
- All Implemented Interfaces:
java.net.http.WebSocket.Listener
public class MockListener extends java.lang.Object implements java.net.http.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 java.lang.String
closedMessage
private int
closedStatus
private java.util.List<MockListener.Message>
messagesReceived
private boolean
open
private java.nio.ByteBuffer
ping
private java.nio.ByteBuffer
pong
-
Constructor Summary
Constructors Constructor Description MockListener()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
assertIsClosed(int status, java.lang.String message)
void
assertIsOpen()
void
assertPing(java.nio.ByteBuffer message)
assert that a ping message was received.void
assertPong(java.nio.ByteBuffer message)
assert that a pong message was received.void
assertReceivedMessage(java.lang.Object message, boolean last)
java.util.concurrent.CompletionStage<?>
onBinary(java.net.http.WebSocket webSocket, java.nio.ByteBuffer data, boolean last)
java.util.concurrent.CompletionStage<?>
onClose(java.net.http.WebSocket webSocket, int statusCode, java.lang.String reason)
void
onError(java.net.http.WebSocket webSocket, java.lang.Throwable error)
void
onOpen(java.net.http.WebSocket webSocket)
java.util.concurrent.CompletionStage<?>
onPing(java.net.http.WebSocket webSocket, java.nio.ByteBuffer message)
java.util.concurrent.CompletionStage<?>
onPong(java.net.http.WebSocket webSocket, java.nio.ByteBuffer message)
java.util.concurrent.CompletionStage<?>
onText(java.net.http.WebSocket webSocket, java.lang.CharSequence data, boolean last)
-
-
-
Field Detail
-
messagesReceived
private java.util.List<MockListener.Message> messagesReceived
-
ping
private java.nio.ByteBuffer ping
-
pong
private java.nio.ByteBuffer pong
-
open
private boolean open
-
closedStatus
private int closedStatus
-
closedMessage
private java.lang.String closedMessage
-
-
Method Detail
-
onOpen
public void onOpen(java.net.http.WebSocket webSocket)
- Specified by:
onOpen
in interfacejava.net.http.WebSocket.Listener
-
onText
public java.util.concurrent.CompletionStage<?> onText(java.net.http.WebSocket webSocket, java.lang.CharSequence data, boolean last)
- Specified by:
onText
in interfacejava.net.http.WebSocket.Listener
-
onBinary
public java.util.concurrent.CompletionStage<?> onBinary(java.net.http.WebSocket webSocket, java.nio.ByteBuffer data, boolean last)
- Specified by:
onBinary
in interfacejava.net.http.WebSocket.Listener
-
onPing
public java.util.concurrent.CompletionStage<?> onPing(java.net.http.WebSocket webSocket, java.nio.ByteBuffer message)
- Specified by:
onPing
in interfacejava.net.http.WebSocket.Listener
-
onPong
public java.util.concurrent.CompletionStage<?> onPong(java.net.http.WebSocket webSocket, java.nio.ByteBuffer message)
- Specified by:
onPong
in interfacejava.net.http.WebSocket.Listener
-
onClose
public java.util.concurrent.CompletionStage<?> onClose(java.net.http.WebSocket webSocket, int statusCode, java.lang.String reason)
- Specified by:
onClose
in interfacejava.net.http.WebSocket.Listener
-
onError
public void onError(java.net.http.WebSocket webSocket, java.lang.Throwable error)
- Specified by:
onError
in interfacejava.net.http.WebSocket.Listener
-
assertReceivedMessage
public void assertReceivedMessage(java.lang.Object message, boolean last)
-
assertIsClosed
public void assertIsClosed(int status, java.lang.String message)
-
assertPing
public void assertPing(java.nio.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(java.nio.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()
-
-