connecting attempt. not only return it to the user, but also react on changes in an async manner.

gistfile1.java

  /**
   * Handle {@link ConnectRequest} messages.
   *
   * @param request the connect request message.
   * @return a {@link ConnectResponse}.
   */
  private Promise<ConnectResponse> handleConnect(ConnectRequest request) {
    if (connected.get()) {
      return Promises.success(ConnectResponse.alreadyConnected()).get();
    } else {
      Promise<ConnectResponse> connectPromise = configProvider.connect(request);
      connectPromise.onSuccess(new Consumer<ConnectResponse>() {
        @Override
        public void accept(ConnectResponse connectResponse) {
          connected.set(true);
        }
      });
      return connectPromise;
    }
  }