Почему ArrayList пустой?

Question

[федор unknown]

У меня есть асинхронный запрос, хочу полученный ответ записать в ArrayList, но у меня почему-что выдает пустой лист.
в чем может быть проблема?
мой код:

public List<Response> getAdditionalData(List<ExcelModel> excelList) throws InterruptedException {
        List<Response> responseList = new ArrayList<>();
        for (ExcelModel excel : excelList) {
            Mono<Response> response = webClient.get()
                    .uri(sybase + excel.getTransactionID())
                    .retrieve()
                    .bodyToMono(Response.class);
            response.subscribe(responseList::add);
        }

        log.info("list size size: {}", responseList.size());
        responseList.forEach(System.out::println);
        return responseList;
    }

Answer 1

[Михаил]

Так запрос же асинхронный. То есть вы его запускаете и говорите "вот когда данные придут - запиши их в список". И не дожидаясь пока запрос выполнится - возвращаете список (который, разумеется, пустой - запрос же еще в процессе выполнения).

Поэтому, если уж вы начали использовать асинхронные запросы - надо жить в асинхронном мире дальше, везде протаскивая Mono и Flux.

Либо переходить на Kotlin с его корутинами (которые прекрасно интегрируются с Mono/Flux)

Answer 2

[Dmitry Roo]

Тут я вижу два варианта.
1. Вы никакой асинхронщины не хотите, но вам попался асинхронный клиент. Тогда нужно что-то типа такого сделать:

public List<Response> getAdditionalData(List<ExcelModel> excelList) {
        return Flux.fromIterable(excelList) // Превращаем лист во флюкс
                .flatMap(excel -> webClient.get()  // по каждому элемену делаем асинхронный запрос
                        .uri(sybase + excel.getTransactionID())
                        .retrieve()
                        .bodyToMono(Response.class))
                .collectList() // Собираем поток в лист. Тут получается Mono<List<Response>>
                .block(); // Блокируем тред и ждем завершения. Можно в скобочках указать сколько ждать.
    }

2. Либо вы пересаживаетесь на асинхронный стек, тогда вам нужно флюкс и отдавать, как и написал Михаил. И подписка на него дожна быть, скорее всего, где-то выше по стеку.

public Flux<Response> getAdditionalData(List<ExcelModel> excelList) {
        return Flux.fromIterable(excelList)
                .flatMap(excel -> webClient.get()
                        .uri(sybase + excel.getTransactionID())
                        .retrieve()
                        .bodyToMono(Response.class));
    }

Comments

[федор unknown]

я могу тут зависимо от ответа взывать сразу же другой запрос с другим url?
например:
я получил в ответ:

{
    "result": false,
    "requisite": "",
    "amount": 0,
    "created": null,
    "suip": null
}

значит вызываю такой же запрос, только с другий URI:
.uri(postgres + excel.getSuip())

[Dmitry Roo]

федор unknown, можно после того как ответ поступил его проанализировать и замапить еще раз. Вообще в этом апи есть куча методов: таймауты, ретраи, подписки на ошибки... Есть что поизучать. Если вы хотите делать повторные запросы по какому-то другому полю, то лучше все что во .flatMap вынести в отдельный метод, в которым уже эти запросы будут как-то организованы.

ps. Не понимаю зачем вам два аккаунта?..

[федор unknown]

Dmitry Roo,

ps. Не понимаю зачем вам два аккаунта?..

- У меня их целых 3! ))))
Из-за ограничений по вопросом.

[Михаил]

федор unknown, да, все это делать можно.
Но при наличии сложной логики в коде начинается большое количество map, flatMap, zip и т.п. методов обработки. Все это было в нашем проекте, продраться через сложную реактивную логику было возможно не только лишь для всех :)

Перешли на kotlin coroutines. Теперь после bodyToMono стоит вызов котлиновского awaitSingle, который служит "мостиком" между миром реактивного программирования и корутинами, а дальше - простой и понятный код, практически в синхронном стиле.

Так что подумайте. Если у вас сложная реактивная логика - я бы очень рекомендовал посмотреть в эту сторону.