Interface Endpoint

    • Method Detail

      • connect

        rx.Observable<LifecycleState> connect()
        Connect the Endpoint to the underlying channel.
        Returns:
        a Observable with the state after the connect process finishes.
      • disconnect

        rx.Observable<LifecycleState> disconnect()
        Disconnect the Endpoint from the underlying channel.
        Returns:
        a Observable with the state after the disconnect process finishes.
      • isFree

        boolean isFree()
        If this endpoint is free to take a request. This is especially important in non-pipelined endpoint cases since if a request is in-flight this will return false.
        Returns:
        true if free to accept a request, false otherwise.
      • lastResponse

        long lastResponse()
        Returns the timestamp of the last response completed.
      • remoteAddress

        String remoteAddress()
        Returns the remote address as String representation. Hostname and port separated by colon.