如何使用Mono.dematerialize()?

How to use Mono.dematerialize()?

作为主题,我不明白什么是用例以及如何使用它。

深入研究源代码似乎是将单声道本身从 Mono<T> 转换为 Mono<Signal<X>

如 javadoc 中所示,dematerialize 只有在调用它的 FluxFlux<Signal<T>>

时才有意义

它是 materialize 的逆向,旨在将源中的每个信号转换为 onNext 通知。

典型用途是监视 Flux 中发生的所有事情,而不仅仅是值信号,然后恢复到原始通量:要模拟 log() 运算符,您可以使用 materialize().doOnNext(System.out::println).dematerialize() 例如...