Skip to content

Commit c6a23fa

Browse files
Merge pull request #1646 from benjchristensen/deprecate-parallel-merge
Deprecate ParallelMerge
2 parents 362aee9 + 65d678d commit c6a23fa

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

rxjava-core/src/main/java/rx/Observable.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2902,7 +2902,9 @@ public final static <T> Observable<T> never() {
29022902
* the number of Observables to merge into
29032903
* @return an Observable of Observables constrained in number by {@code parallelObservables}
29042904
* @see <a href="https://github.com/Netflix/RxJava/wiki/Combining-Observables#parallelmerge">RxJava wiki: parallelMerge</a>
2905+
* @deprecated will be removed in 1.0
29052906
*/
2907+
@Deprecated
29062908
public final static <T> Observable<Observable<T>> parallelMerge(Observable<Observable<T>> source, int parallelObservables) {
29072909
return OperatorParallelMerge.parallelMerge(source, parallelObservables);
29082910
}
@@ -2931,7 +2933,9 @@ public final static <T> Observable<Observable<T>> parallelMerge(Observable<Obser
29312933
* the {@link Scheduler} to run each Observable on
29322934
* @return an Observable of Observables constrained in number by {@code parallelObservables}
29332935
* @see <a href="https://github.com/Netflix/RxJava/wiki/Combining-Observables#parallelmerge">RxJava wiki: parallelMerge</a>
2936+
@deprecated will be removed in 1.0
29342937
*/
2938+
@Deprecated
29352939
public final static <T> Observable<Observable<T>> parallelMerge(Observable<Observable<T>> source, int parallelObservables, Scheduler scheduler) {
29362940
return OperatorParallelMerge.parallelMerge(source, parallelObservables, scheduler);
29372941
}

0 commit comments

Comments
 (0)