diff --git a/reactor-core/src/main/java/reactor/core/publisher/Mono.java b/reactor-core/src/main/java/reactor/core/publisher/Mono.java index 56aabfcb5a..d131415fe2 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/Mono.java +++ b/reactor-core/src/main/java/reactor/core/publisher/Mono.java @@ -2213,7 +2213,7 @@ public final Mono doOnSubscribe(Consumer onSubscribe) { * * *

- * + * * * @param onSuccessOrError the callback to call {@link Subscriber#onNext}, {@link Subscriber#onComplete} without preceding {@link Subscriber#onNext} or {@link Subscriber#onError} * diff --git a/reactor-core/src/main/java/reactor/core/publisher/doc-files/marbles/doOnSuccessOrError.svg b/reactor-core/src/main/java/reactor/core/publisher/doc-files/marbles/doOnSuccessOrError.svg new file mode 100644 index 0000000000..d4a13a7499 --- /dev/null +++ b/reactor-core/src/main/java/reactor/core/publisher/doc-files/marbles/doOnSuccessOrError.svg @@ -0,0 +1,131 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + doOnSuccessOrError(( + + + ) + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + , + + + + + + + ) + + + ... + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +