Package kong.unirest.core

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()