Создавайте издателя динамически с условиями

Question

Я просто ищу идею для преобразования этого псевдокода в реактивный стиль.

var records = new ArrayList<>(); 

var query   = new Query();
var results = query.executeQuery();
records.addAll(results.getRecords());

while (results.hasMore()) {
query = new Query(results.offset())
deals = hubspotQuery.executeQuery(Deals.class);
records.addAll(results.getRecords());
}

Идея состоит в том, чтобы собрать все записи в Flux

Answer 1

Вот одно из возможных решений. Может быть, есть другие, но этот простой. Это не настоящий код, но он описывает логику.

Flux<Records> query = createFluxQuery(); query.expand(record -> (record.hasMore()) ? createFluxQuery(record.offset) : Flux.empty());