Skip to content

Commit

Permalink
javadoc fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
Stephane Maldini committed Sep 5, 2017
1 parent 92e5953 commit 053727e
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 7 deletions.
6 changes: 4 additions & 2 deletions reactor-core/src/main/java/reactor/core/publisher/Flux.java
Original file line number Diff line number Diff line change
Expand Up @@ -6371,7 +6371,8 @@ public final Flux<T> subscriberContext(Function<Context, Context> doOnContext) {
* context of onNext/onError/onComplete signals from the beginning of the chain up to
* the next occurrence of a {@link #publishOn(Scheduler) publishOn}.
* <p>
* 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.
Expand Down Expand Up @@ -6407,7 +6408,8 @@ public final Flux<T> 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}.
* <p>
* 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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2931,7 +2931,7 @@ public final Mono<T> 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.
Expand Down
4 changes: 2 additions & 2 deletions reactor-core/src/main/java/reactor/util/context/Context.java
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
4 changes: 2 additions & 2 deletions reactor-test/src/main/java/reactor/test/StepVerifier.java
Original file line number Diff line number Diff line change
Expand Up @@ -283,8 +283,8 @@ static <T> FirstStep<T> 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;

Expand Down

0 comments on commit 053727e

Please sign in to comment.