Skip to content

Commit

Permalink
Merge #3874 into 3.7.0-M6
Browse files Browse the repository at this point in the history
  • Loading branch information
chemicL committed Aug 19, 2024
2 parents 5479a6a + 63d25e9 commit 35651b0
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 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 @@ -2035,7 +2035,7 @@ public static Flux<Integer> range(int start, int count) {
* @param mergedPublishers The {@link Publisher} of {@link Publisher} to switch on and mirror.
* @param <T> the produced type
*
* @return a {@link SinkManyAbstractBase} accepting publishers and producing T
* @return a {@link Flux} accepting publishers and producing T
*/
public static <T> Flux<T> switchOnNext(Publisher<? extends Publisher<? extends T>> mergedPublishers) {
return onAssembly(new FluxSwitchMapNoPrefetch<>(from(mergedPublishers),
Expand All @@ -2056,7 +2056,7 @@ public static <T> Flux<T> switchOnNext(Publisher<? extends Publisher<? extends T
* @param prefetch the inner source request size
* @param <T> the produced type
*
* @return a {@link SinkManyAbstractBase} accepting publishers and producing T
* @return a {@link Flux} accepting publishers and producing T
*
* @deprecated to be removed in 3.6.0 at the earliest. In 3.5.0, you should replace
* calls with prefetch=0 with calls to switchOnNext(mergedPublishers), as the default
Expand Down

0 comments on commit 35651b0

Please sign in to comment.