Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
作为主题,我不明白用例是什么以及如何使用它。
深入研究源代码似乎是将单声道本身Mono<T>从Mono<Signal<X>.
Mono<T>
Mono<Signal<X>
如 javadoc 中所示,dematerialize只有Flux在调用它的时候才有意义Flux<Signal<T>>
dematerialize
Flux
Flux<Signal<T>>
它是 的倒数materialize,旨在将源中的每个信号都转换为onNext通知。
materialize
onNext
典型用途是监视 a 中发生的所有事情Flux,而不仅仅是值信号,然后恢复到原始通量:要模拟log()运算符,您可以使用materialize().doOnNext(System.out::println).dematerialize()例如...
log()
materialize().doOnNext(System.out::println).dematerialize()