最近，我的一位同事向我介绍了Project Reactor类型的expand运算符，在这篇文章中，我想介绍几种使用它的方式。
展开分页结果
考虑在名为City的模型上基于Spring Data的存储库：
import org.springframework.data.jpa.repository.JpaRepository; import samples.geo.domain.City; public interface CityRepo extends JpaRepository<City, Long> { } 该存储库提供了一种检索分页结果的方法，大致如下：
cityRepo.findAll(PageRequest.of( 0 , 5 )) 现在，如果我要将多个页面展开到一个结果中，执行此操作的方法将是以下一种循环：
var pageable: Pageable = PageRequest.of( 0 , 5 ) do { var page: Page<City> = cityRepo.findAll(pageable) page.content.forEach { city -> LOGGER.info( "City $city" ) } pageable = page.nextPageable() } while (page.hasNext()) 可以使用Reactor expand运算符通过以下方式完成分页结果的等效展开：
val result: Flux<City> = Mono .fromSupplier { cityRepo.findAll(PageRequest.of( 0 , 5 )) } .expand { page -> if (page.hasNext()) Mono.fromSupplier { cityRepo.findAll(page.nextPageable()) } else Mono.empty() } .flatMap { page -> Flux.fromIterable(page.content) } result.subscribe( { page -> LOGGER.info( "City ${page}" ) }, { t -> t.printStackTrace() } ) 在这里，结果的第一页扩展到第二页，第二页扩展到第三页，依此类推，直到没有要检索的页面为止。
遍历一棵树
考虑以下模型表示的树结构中的节点：
data class Node( val id: String, val nodeRefs: List<String>, ) 样本数据如下所示：
可以使用如下所示的调用遍历：
val rootMono: Mono<Node> = nodeService.getNode( "1" ) val expanded: Flux<Node> = rootMono.expand { node -> Flux.fromIterable(node.childRefs) .flatMap { nodeRef -> nodeService.getNode(nodeRef) } } expanded.subscribe { node -> println(node) } 这是广度优先的扩展，输出如下所示：
Node- 1 Node- 1 - 1 Node- 1 - 2 Node- 1 - 1 - 1 Node- 1 - 1 - 2 Node- 1 - 2 - 1 Node- 1 - 2 - 2 expandDeep变体将深度优先遍历
翻译自: https://www.javacodegeeks.com/2020/02/project-reactor-expand-method.html
