Merge pull request #1716 from benjchristensen/remove-parallel

Remove Observable.Parallel

Author: benjchristensen

src/main/java/rx/Observable.java

@@ -5425,52 +5425,6 @@ public final Observable<T> onExceptionResumeNext(final Observable<? extends T> r
         return lift(new OperatorOnExceptionResumeNextViaObservable<T>(resumeSequence));
     }
 
-    /**
-     * Performs work on the source Observable in parallel by sharding it on a {@link Schedulers#computation()}
-     * {@link Scheduler}, and returns the resulting Observable.
-     * <p>
-     * <img width="640" height="475" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/parallel.png" alt="">
-     * <dl>
-     *  <dt><b>Scheduler:</b></dt>
-     *  <dd>{@code parallel} operates by default on the {@code computation} {@link Scheduler}.</dd>
-     * </dl>
-     * 
-     * @param f
-     *            a {@link Func1} that applies Observable Operators to {@code Observable<T>} in parallel and
-     *            returns an {@code Observable<R>}
-     * @return an Observable that emits the results of applying {@code f} to the items emitted by the source
-     *         Observable
-     * @see <a href="https://github.com/ReactiveX/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>
-     */
-    public final <R> Observable<R> parallel(Func1<Observable<T>, Observable<R>> f) {
-        return parallel(f, Schedulers.computation());
-    }
-
-    /**
-     * Performs work on the source Observable<T> in parallel by sharding it on a {@link Scheduler}, and returns
-     * the resulting Observable.
-     * <p>
-     * <img width="640" height="475" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/parallel.png" alt="">
-     * <dl>
-     *  <dt><b>Scheduler:</b></dt>
-     *  <dd>you specify which {@link Scheduler} this operator will use</dd>
-     * </dl>
-     * 
-     * @param f
-     *            a {@link Func1} that applies Observable Operators to {@code Observable<T>} in parallel and
-     *            returns an {@code Observable<R>}
-     * @param s
-     *            a {@link Scheduler} to perform the work on
-     * @return an Observable that emits the results of applying {@code f} to the items emitted by the source
-     *         Observable
-     * @see <a href="https://github.com/ReactiveX/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>
-     */
-    public final <R> Observable<R> parallel(final Func1<Observable<T>, Observable<R>> f, final Scheduler s) {
-        return lift(new OperatorParallel<T, R>(f, s));
-    }
-
     /**
      * Returns a {@link ConnectableObservable}, which waits until its
      * {@link ConnectableObservable#connect connect} method is called before it begins emitting items to those