Async coordination (Futures)

Future<Void> fut1 = Future.future();
Future<Void> fut2 = Future.future();
HttpClient.request(
            HttpMethod.GET,
            "/some_url",
            handler -> {
                if (handler.statusCode() == 200) {
                    handler.bodyHandler(body -> {
                        // do sth..
                        this.els = "ddd";
                        fut1.complete();
                        System.out.println("fut11.complete?: " + fut1.isComplete());
                    });
                }
            }
        ).end();
 
System.out.println("fut12.complete?: "+fut1.isComplete()); // возвращает false, т.к. выполняется раньше bodyHandler-а
 
fut1.compose(h -> {
            System.out.println("ELS_fut: " + this.els); // возвращает "ddd"
        }, fut2);

fut1.complete();

fut1.compose

  @Override
  public void complete() {
    complete(null);
  }
 
  /**
   * Set the result. Any handler will be called, if there is one
   */
  public void complete(T result) {
    checkComplete();
    this.result = result;
    succeeded = true;
    checkCallHandler();
  }
  private void checkCallHandler() {
    if (handler != null && isComplete()) {
      handler.handle(this);
    }
  }