diff --git a/reactor-core/src/main/java/reactor/core/publisher/Flux.java b/reactor-core/src/main/java/reactor/core/publisher/Flux.java index db3421f4a6..967d355f61 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/Flux.java +++ b/reactor-core/src/main/java/reactor/core/publisher/Flux.java @@ -6371,7 +6371,8 @@ public final Flux subscriberContext(Function doOnContext) { * context of onNext/onError/onComplete signals from the beginning of the chain up to * the next occurrence of a {@link #publishOn(Scheduler) publishOn}. *

- * Note that if you are using an eager or blocking {@link #create(Consumer, OverflowStrategy)} + * Note that if you are using an eager or blocking + * {@link Flux#create(Consumer, OverflowStrategy)} * as the source, it can lead to deadlocks due to requests piling up behind the emitter. * In such case, you should call {@link #subscribeOn(Scheduler, boolean) subscribeOn(scheduler, false)} * instead. @@ -6407,7 +6408,8 @@ public final Flux subscribeOn(Scheduler scheduler) { * context of onNext/onError/onComplete signals from the beginning of the chain up to * the next occurrence of a {@link #publishOn(Scheduler) publishOn}. *

- * Note that if you are using an eager or blocking {@link #create(Consumer, OverflowStrategy)} + * Note that if you are using an eager or blocking + * {@link Flux#create(Consumer, OverflowStrategy)} * as the source, it can lead to deadlocks due to requests piling up behind the emitter. * Thus this operator has a {@code requestOnSeparateThread} parameter, which should be * set to {@code false} in this case. 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 0b3865624e..a2ab70810e 100644 --- a/reactor-core/src/main/java/reactor/core/publisher/Mono.java +++ b/reactor-core/src/main/java/reactor/core/publisher/Mono.java @@ -2931,7 +2931,7 @@ public final Mono take(Duration duration) { * The timeframe is evaluated using the provided {@link Scheduler}. * * @param duration the maximum duration to wait for the source Mono to resolve. - * @parama timer the {@link Scheduler} on which to measure the duration. + * @param timer the {@link Scheduler} on which to measure the duration. * * @return a new {@link Mono} that will propagate the signals from the source unless * no signal is received for {@code duration}, in which case it completes. diff --git a/reactor-core/src/main/java/reactor/util/context/Context.java b/reactor-core/src/main/java/reactor/util/context/Context.java index fef5ca3b38..b696115cd9 100644 --- a/reactor-core/src/main/java/reactor/util/context/Context.java +++ b/reactor-core/src/main/java/reactor/util/context/Context.java @@ -122,8 +122,8 @@ static Context of(Object key1, Object value1, * @param value3 the value for the third key. * @param key4 the fourth key to initialize. * @param value4 the value for the fourth key. - * @param key4 the fifth key to initialize. - * @param value4 the value for the fifth key. + * @param key5 the fifth key to initialize. + * @param value5 the value for the fifth key. * @return a {@link Context} with five entries. */ static Context of(Object key1, Object value1, diff --git a/reactor-test/src/main/java/reactor/test/StepVerifier.java b/reactor-test/src/main/java/reactor/test/StepVerifier.java index 48e27706f7..78fcb9aa60 100644 --- a/reactor-test/src/main/java/reactor/test/StepVerifier.java +++ b/reactor-test/src/main/java/reactor/test/StepVerifier.java @@ -283,8 +283,8 @@ static FirstStep withVirtualTime( * * @return the actual {@link Duration} the verification took. * @throws AssertionError in case of expectation failures - * @see #verify(Duration) verify(Duration) to put a specific timeout - * @see #setDefaultTimeout setDefaultTimeout(Duration) to change the global default timeout + * @see #verify(Duration) + * @see #setDefaultTimeout(Duration) */ Duration verify() throws AssertionError;