如何使用Mono.dematerialize()?
How to use Mono.dematerialize()?
作为主题,我不明白什么是用例以及如何使用它。
深入研究源代码似乎是将单声道本身从 Mono<T>
转换为 Mono<Signal<X>
。
如 javadoc 中所示,dematerialize
只有在调用它的 Flux
是 Flux<Signal<T>>
时才有意义
它是 materialize
的逆向,旨在将源中的每个信号转换为 onNext
通知。
典型用途是监视 Flux
中发生的所有事情,而不仅仅是值信号,然后恢复到原始通量:要模拟 log()
运算符,您可以使用 materialize().doOnNext(System.out::println).dematerialize()
例如...
作为主题,我不明白什么是用例以及如何使用它。
深入研究源代码似乎是将单声道本身从 Mono<T>
转换为 Mono<Signal<X>
。
如 javadoc 中所示,dematerialize
只有在调用它的 Flux
是 Flux<Signal<T>>
它是 materialize
的逆向,旨在将源中的每个信号转换为 onNext
通知。
典型用途是监视 Flux
中发生的所有事情,而不仅仅是值信号,然后恢复到原始通量:要模拟 log()
运算符,您可以使用 materialize().doOnNext(System.out::println).dematerialize()
例如...