你应该什么时候屏蔽/订阅Mono/Flux？

Question

假设你有一些焊剂和monos

val people: Flux<Person> = repo.getPeople()
val peopleCount: Mono<Int> = people.count()

从WebFlux控制器返回一个单声道

data class Response(
    val people: List<People>,
    val personCount: Int
)

在应用程序中，将通量和单声道分别解析为List和Int的合适位置在哪里？您只是阻止（）所有内容吗？有没有办法获得解决所有问题的框架？

编辑：我想我的主要困惑是，我看到的所有教程中，响应对象内的字段实际上都不是反应性的，所以似乎我需要在从控制器返回对象之前解决所有问题。如果响应对象看起来像这样，我会觉得更有意义

data class Response(
    val people: Flux<People>,
    val personCount: Mono<Int>
)

Answer 1

如果您在servlet世界中使用Reactor，您只能阻止，即使这样，您也可以传回Mono/Flux，这将是一个异步请求。

给你举个例子，比如，

return repo.getPeople().collectList().map( people -> new response(peoples, people.count())

最后是单声道编码

您需要在Mono/Flux上使用运算符，而不是阻塞反应链。我建议查看Reactorjava文档。每个运算符都有很好的图表，可以直观地看到运算符在做什么。