有没有办法通过 while 循环内 api 的 Mono.fromCallable() 返回值来更新局部变量？

Question

我需要多次运行 GET 请求，直到 GET 返回空数组为止。 目前，我一直在使用全局 receiveAllApiData 变量来完成此操作，如果它是空数组，我会在 getApiValues 中更新它。但是我需要找到一种方法在本地方法中执行此操作。有没有办法 mono.fromCallable 可以更改局部变量？

while (!receivedAllApiData && offsetAmount < MAX_REQUEST_FALLBACK) {
            int offset = offset;
            Mono.fromCallable(() -> Api.getApiValues(Id, offset, LIMIT, property))
                    .map(this::getApiValues)
                    .subscribe(this::buildStructure, this::ErrorCounter);
            offsetAmount += LIMIT;
        }

也许有更好的方法来运行多个调用？

Answer 1

使用atomicBoolean，您可以更新映射函数内的值，如下所示。

       AtomicBoolean receivedAllApiData = new AtomicBoolean(false);

        while (!!receivedAllApiData.get() && offsetAmount < MAX_REQUEST_FALLBACK) {
            int offset = offsetAmount;
            Mono.fromCallable(() -> Api.getApiValues(Id, offset, LIMIT, property))
                    .map(listOfValues -> {
                        List<Values> nonNullListOfValues = CollectionUtils.isEmpty(listOfValues) ? emptyList() : listOfValues;
                        receivedAllApiData.set(nonNullListOfValues.isEmpty());
                        return nonNullListOfValues;
                    })
                    .subscribe(this::buildStructure, this::ErrorCounter);
            offsetAmount += LIMIT;
        }