Java Reactor Flux/Mono，在元素发出之前或之后什么时候触发 doOnNext？

Question

我有这个困惑，什么时候 doOnNext 是在 Publisher (Flux/Mono) 元素发射之前或之后触发的。

Answer 1

它在元素发布之后 - 并且它必须在定义之后，否则 Consumer传递给 doOnNext将无法访问发出的元素。

然而，doOnNext()在订阅者之前调用。例如:

Flux.just("first", "second")
        .doOnNext(x -> System.out.println(x + " onNext"))
        .subscribe(System.out::println);

...会输出:

first onNext
first
second onNext
second