Class 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  
    • 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)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • 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
    • Constructor Detail

      • MockListener

        public MockListener()
    • Method Detail

      • onOpen

        public void onOpen​(java.net.http.WebSocket webSocket)
        Specified by:
        onOpen in interface java.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 interface java.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 interface java.net.http.WebSocket.Listener
      • onPing

        public java.util.concurrent.CompletionStage<?> onPing​(java.net.http.WebSocket webSocket,
                                                              java.nio.ByteBuffer message)
        Specified by:
        onPing in interface java.net.http.WebSocket.Listener
      • onPong

        public java.util.concurrent.CompletionStage<?> onPong​(java.net.http.WebSocket webSocket,
                                                              java.nio.ByteBuffer message)
        Specified by:
        onPong in interface java.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 interface java.net.http.WebSocket.Listener
      • onError

        public void onError​(java.net.http.WebSocket webSocket,
                            java.lang.Throwable error)
        Specified by:
        onError in interface java.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()