Skip to content

Commit

Permalink
Merge pull request #1715 from benjchristensen/deprecate-parallel
Browse files Browse the repository at this point in the history
Deprecate Parallel
  • Loading branch information
benjchristensen committed Oct 2, 2014
2 parents 56778fd + ef72a6f commit 95f192a
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions rxjava-core/src/main/java/rx/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -6312,6 +6312,7 @@ public final Observable<T> onExceptionResumeNext(final Observable<? extends T> r
* Observable
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#parallel">RxJava wiki: parallel</a>
* @see <a href="http://www.grahamlea.com/2014/07/rxjava-threading-examples/">RxJava Threading Examples</a>
* @deprecated see https://github.com/ReactiveX/RxJava/issues/1673
*/
public final <R> Observable<R> parallel(Func1<Observable<T>, Observable<R>> f) {
return parallel(f, Schedulers.computation());
Expand All @@ -6336,6 +6337,7 @@ public final <R> Observable<R> parallel(Func1<Observable<T>, Observable<R>> f) {
* Observable
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#parallel">RxJava wiki: parallel</a>
* @see <a href="http://www.grahamlea.com/2014/07/rxjava-threading-examples/">RxJava Threading Examples</a>
* @deprecated see https://github.com/ReactiveX/RxJava/issues/1673
*/
public final <R> Observable<R> parallel(final Func1<Observable<T>, Observable<R>> f, final Scheduler s) {
return lift(new OperatorParallel<T, R>(f, s));
Expand Down

0 comments on commit 95f192a

Please sign in to comment.