Skip to content

Commit 9826fc9

Browse files
Restoring parallel() to using Schedulers.computation()
See #713 for background on this.
1 parent 3759b0e commit 9826fc9

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5079,9 +5079,7 @@ public final Observable<T> onExceptionResumeNext(final Observable<? extends T> r
50795079
* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#wiki-parallel">RxJava Wiki: parallel()</a>
50805080
*/
50815081
public final <R> Observable<R> parallel(Func1<Observable<T>, Observable<R>> f) {
5082-
// TODO move this back to Schedulers.computation() again once that is properly using eventloops
5083-
// see https://github.com/Netflix/RxJava/issues/713 for why this was changed
5084-
return lift(new OperatorParallel<T, R>(f, Schedulers.newThread()));
5082+
return lift(new OperatorParallel<T, R>(f, Schedulers.computation()));
50855083
}
50865084

50875085
/**

0 commit comments

Comments
 (0)