Java 中的 Mono<List<Object>> 到 List<Object>

Question

我无法将Mono<List<Object>> 处理为List<Object>。我在某处读到可以使用flatmap，但我也无法做到这一点。我不想在这种情况下使用.block() 方法。

代码示例可以是：

PagePublisher<Address> someAddressPage = someService.getPagePublisherForAddress();
Mono<List<Address>> addressListMono = 
       Flux.from(someAddressPage.items()).collectList();

我需要从Mono<List<Address>> 获取List<Address>。方法返回类型为List<Address>。

我不知道该怎么做，而且我对响应式比较陌生。在这方面需要帮助。

Answer 1

不可能从Mono<List<Address>> 得到List<Address>。如果 List 尚不可用，因为 Mono 和 Flux 本质上是异步/非阻塞的，除非等待它进入，否则您无法获得它，这就是阻塞。

理想情况下，您的方法应返回Mono<List<Address>> 或仅返回Flux<Address>，并且此方法的调用者应订阅结果。由于您使用的是 Spring Webflux，因此完整的链应该是响应式的。

您可以从调用方法订阅Mono，当它可用时，您传递的订阅者将获得List。例如

addressListMono.subscribe(
  addressList -> doSomething(addressList), 
  error -> error.printStackTrace(), 
  () -> Console.out.println("completed without a value")
)

Answer 2

使用block() 实际上是在发出Mono 时从Mono 获取对象的唯一方法。但是，您应该不惜一切代价避免它，因为它违背了使用反应式堆栈的目的，因为它实际上阻塞了等待从Mono 发出对象的线程。

这意味着在使用响应式编程时，您实际上应该使用Mono 和Flux，以便您的应用程序真正具有响应式。这样做的结果是您必须将方法的返回类型更改为返回 Mono<List<Address>>。