java - Java Reactor Flux/Mono，何时在元素发出之前或之后触发doOnNext？

我感到困惑，是何时发布者在元素发射之前(Flux / Mono)触发doOnNext。

最佳答案

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

但是，doOnNext()在订阅者之前被调用。例如:

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

...将输出:

first onNext
first
second onNext
second