Interface ClientWebSocket

    • Method Detail

      • connect

        Future<WebSocket> connect​(WebSocketConnectOptions options)
        Connect this WebSocket with the specified options.
        Parameters:
        options - the request options
        Returns:
        a future notified when the WebSocket when connected
      • connect

        default Future<WebSocket> connect​(int port,
                                          String host,
                                          String requestURI)
        Connect this WebSocket to the specified port, host and relative request URI.
        Parameters:
        port - the port
        host - the host
        requestURI - the relative URI
        Returns:
        a future notified when the WebSocket when connected
      • connect

        default Future<WebSocket> connect​(String host,
                                          String requestURI)
        Connect this WebSocket to the host and relative request URI and default port.
        Parameters:
        host - the host
        requestURI - the relative URI
        Returns:
        a future notified when the WebSocket when connected
      • connect

        default Future<WebSocket> connect​(String requestURI)
        Connect this WebSocket at the relative request URI using the default host and port.
        Parameters:
        requestURI - the relative URI
        Returns:
        a future notified when the WebSocket when connected
      • pause

        ClientWebSocket pause()
        Description copied from interface: ReadStream
        Pause the ReadStream, it sets the buffer in fetch mode and clears the actual demand.

        While it's paused, no data will be sent to the data handler.

        Specified by:
        pause in interface ReadStream<Buffer>
        Specified by:
        pause in interface WebSocket
        Specified by:
        pause in interface WebSocketBase
        Returns:
        a reference to this, so the API can be used fluently
      • resume

        default ClientWebSocket resume()
        Description copied from interface: ReadStream
        Resume reading, and sets the buffer in flowing mode.

        If the ReadStream has been paused, reading will recommence on it.

        Specified by:
        resume in interface ReadStream<Buffer>
        Specified by:
        resume in interface WebSocket
        Specified by:
        resume in interface WebSocketBase
        Returns:
        a reference to this, so the API can be used fluently
      • fetch

        ClientWebSocket fetch​(long amount)
        Description copied from interface: ReadStream
        Fetch the specified amount of elements. If the ReadStream has been paused, reading will recommence with the specified amount of items, otherwise the specified amount will be added to the current stream demand.
        Specified by:
        fetch in interface ReadStream<Buffer>
        Specified by:
        fetch in interface WebSocket
        Specified by:
        fetch in interface WebSocketBase
        Returns:
        a reference to this, so the API can be used fluently
      • setWriteQueueMaxSize

        ClientWebSocket setWriteQueueMaxSize​(int maxSize)
        Description copied from interface: WriteStream
        Set the maximum size of the write queue to maxSize. You will still be able to write to the stream even if there is more than maxSize items in the write queue. This is used as an indicator by classes such as Pipe to provide flow control.

        The value is defined by the implementation of the stream, e.g in bytes for a NetSocket, etc...

        Specified by:
        setWriteQueueMaxSize in interface WebSocket
        Specified by:
        setWriteQueueMaxSize in interface WebSocketBase
        Specified by:
        setWriteQueueMaxSize in interface WriteStream<Buffer>
        Parameters:
        maxSize - the max size of the write stream
        Returns:
        a reference to this, so the API can be used fluently
      • drainHandler

        ClientWebSocket drainHandler​(Handler<Void> handler)
        Description copied from interface: WriteStream
        Set a drain handler on the stream. If the write queue is full, then the handler will be called when the write queue is ready to accept buffers again. See Pipe for an example of this being used.

        The stream implementation defines when the drain handler, for example it could be when the queue size has been reduced to maxSize / 2.

        Specified by:
        drainHandler in interface WebSocket
        Specified by:
        drainHandler in interface WebSocketBase
        Specified by:
        drainHandler in interface WriteStream<Buffer>
        Parameters:
        handler - the handler
        Returns:
        a reference to this, so the API can be used fluently
      • pongHandler

        ClientWebSocket pongHandler​(Handler<Buffer> handler)
        Description copied from interface: WebSocketBase
        Set a pong frame handler on the connection. This handler will be invoked every time a pong frame is received on the server, and can be used by both clients and servers since the RFC 6455 section 5.5.2 and section 5.5.3 do not specify whether the client or server sends a ping.

        Pong frames may be at most 125 bytes (octets).

        There is no ping handler since ping frames should immediately be responded to with a pong frame with identical content

        Pong frames may be received unsolicited.

        Specified by:
        pongHandler in interface WebSocket
        Specified by:
        pongHandler in interface WebSocketBase
        Parameters:
        handler - the handler
        Returns:
        a reference to this, so the API can be used fluently