kotlin - Reactor-加载分页API的所有页面

Question

我想知道Reactor和分页的HTTP API。我有一个private fun getPage(pageNumber: Int): Mono<SomePaginatedResouce>。该资源具有“numberOfPages”字段，我想获取所有页面。

第一次尝试如下:

getPage(1)
    .map { it.numberOfPages }
    .flatMapMany { Flux.range(1, it) }
    .flatMap { getPage(it) }

它可以正常工作并获取我的数据。但是，我想避免两次请求首页。所以我在想:

getPage(1)
    .expand { it ->
        if (it.isFirst) {
            // If it is the first page, load the rest of the pages
            Flux.range(2, it.numberOfPages)
                    .flatMap { getPage(it) }
        } else {
            // If it is a subsequent page, don't load anything
            Flux.empty()
        }
    }

有没有比使用expand并在我的资源中引入特殊标志更好的方法呢？

Answer 1

您可以执行以下操作:

getPage(1).flatMapMany(
        it -> Flux.concat(Mono.just(it), Flux.range(2, it.numberOfPages - 1).flatMap(this::getPage))
);

害怕它是Java而不是Kotlin，但翻译起来应该微不足道。

(请记住，Flux.range()适用于“开始”和“计数”参数，而不适用于“第一个索引”和“最后一个索引”。)