0

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

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

4

1 回答 1

2

如 javadoc 中所示,dematerialize只有Flux在调用它的时候才有意义Flux<Signal<T>>

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

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

于 2017-01-09T12:55:57.160 回答