Sergey Shvyrev

1. Избавляемся от конкретизации интерфейса CompletionStage. Тру реакционщики пишут свои интерпретации.
   
2. Абстрагируемся от возвращаемого значения посредством интерфейса или абстрактного классаю Например DBResponse. Завтра вам надоест мускул, уйдете в носкул. Достаточно будет интерфейс переписать.
   
3. Унифицируем получение данных, вынося в сигнатуру метода однотипные переменные. queryAsync Завтра смените DSL на jooq - достаточно будет только один метод переписать.
   
4. Постарайтесь избавиться от JOIN. Очень дорогой метод, грубо приводящий реактивное программирование к императивному. Используйте thenAcceptAsync, exceptionallyAsync, handleAsync Метод result()
   

public CompletionStage<DBResponse> query1(){
        return queryAsync(jdbc, sql, param1, param2, ... paramN);
    }

    public CompletionStage<DBResponse> query2(){
        return queryAsync(jdbc, sql, param2, param3, ... paramN);
    }

    public CompletionStage<DBResponse> queryAsync(JDBC jdbc, sql, Objects ... params){
        return CompletableFuture.supplyAsync(() -> {
            return jdbc.query(sql, params);
        }).thenApplyAsync(DBResponse::of);
    }

//    далее в коде

    void result(){
        CompletableFuture.allOf(query1(), query2())
                .thenAcceptAsync( ... );
    }

    public static interface DBResponse {
        default DBResponse of(Response resp){
            ...;
        }
    }

var cookieHandler = new CookieManager();
        CookieHandler.setDefault(cookieHandler);
       var executor = Executors.newWorkStealingPool(10);
       var httpClient = HttpClient.newBuilder()
                .executor(executor)
                .connectTimeout(Duration.ofSeconds(15))
                .version(HttpClient.Version.HTTP_2)
                .followRedirects(HttpClient.Redirect.ALWAYS)
                .cookieHandler(CookieHandler.getDefault())
                .build();

final HttpRequest httpRequest = HttpRequest.newBuilder()
                .GET().uri(URI.create(url))
                .build();
        return httpClient.sendAsync(httpRequest, RESPONSE_BODY_HANDLER)
                .thenApply(response -> System.out.println(response.statusCode()));