根据条件动态创建发布者

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());

根据条件动态创建发布者

Create publisher dynamically with conditions

reactor