Реактивное программирование на Java — извлекайте страницы одну за другой и обрабатывайте каждую страницу параллельно. ⇐ JAVA

[Anonymous]

Я хочу перебрать результаты запросов к базе данных, которые разбиты на страницы, и обработать каждую страницу. Обработка каждой страницы должна происходить параллельно, и следующая страница не будет загружена до завершения обработки текущей страницы.
Изменить:
Страницы извлекаются последовательно. , но обработка каждого элемента на странице должна происходить параллельно
Сейчас у меня есть что-то вроде этого:

Код: Выделить всё

Flux.generate( () -> 0, (pageNum, sink) -> {
boolean success = fetchAndProcessPage(pageNum);
if(isLastPage()){
sink.complete()
}
return pageNum +1;
});

boolean fetchAndProcessPage(int pageNum) {
return Flux.fromIterable(getPage(pageNum).getContent())
.parallel()
.runOn(Schedulers.parallel())
.map(this::processItem)
.sequential()
.collectList()
.map( list -> list.stream().allMatch(success -> success)
.block()
}

Это упрощенная версия кода, но она представляет ту же реактивную последовательность.
Моя проблема с этим кодом заключается в том, что fetchAndProcessPage запускается внутри метода генерации и использует блок( ), чтобы завершить обработку страницы.
Есть ли более элегантный способ сделать это без использования блока в fetchAndProcessPage?

Подробнее здесь: https://stackoverflow.com/questions/784 ... ge-in-para