Reactor

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() 适用于 "start" 和 "count" 参数，而不是 "first index" 和 "last index"。）

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

Reactor - Load all pages of a paginated API

kotlin

project-reactor