tempredirect
diff --git a/‎rxjava-core/src/main/java/rx/Observable.java‎
Lines changed: 3 additions & 3 deletions b/‎rxjava-core/src/main/java/rx/Observable.java‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎rxjava-core/src/main/java/rx/operators/OperationMerge.java‎
Lines changed: 0 additions & 230 deletions b/‎rxjava-core/src/main/java/rx/operators/OperationMerge.java‎
Lines changed: 0 additions & 230 deletions
diff --git a/‎rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java‎
Lines changed: 1 addition & 1 deletion b/‎rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java‎
Lines changed: 1 addition & 1 deletion
@@ -62,7 +62,7 @@
 import rx.operators.OperationJoinPatterns;
 import rx.operators.OperatorMap;
 import rx.operators.OperationMaterialize;
-import rx.operators.OperationMerge;
+import rx.operators.OperatorMerge;
 import rx.operators.OperationMergeDelayError;
 import rx.operators.OperationMinMax;
 import rx.operators.OperationMulticast;
@@ -1902,7 +1902,7 @@ public final static <T> Observable<T> merge(Iterable<? extends Observable<? exte
      * @see <a href="http://msdn.microsoft.com/en-us/library/hh229099.aspx">MSDN: Observable.Merge</a>
      */
     public final static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source) {
-        return create(OperationMerge.merge(source));
+        return source.bind(new OperatorMerge()); // any idea how to get these generics working?!
     }
 
     /**
@@ -1926,7 +1926,7 @@ public final static <T> Observable<T> merge(Observable<? extends Observable<? ex
      * @see <a href="http://msdn.microsoft.com/en-us/library/hh211914.aspx">MSDN: Observable.Merge</a>
      */
     public final static <T> Observable<T> merge(Observable<? extends Observable<? extends T>> source, int maxConcurrent) {
-        return create(OperationMerge.merge(source, maxConcurrent));
+        return source.bind(new OperatorMerge(maxConcurrent)); // any idea how to get these generics working?!
     }
 
     /**
 
@@ -28,7 +28,7 @@
 import rx.util.CompositeException;
 
 /**
- * This behaves like {@link OperationMerge} except that if any of the merged Observables notify of
+ * This behaves like {@link OperatorMerge} except that if any of the merged Observables notify of
  * an error via <code>onError</code>, mergeDelayError will refrain from propagating that error
  * notification until all of the merged Observables have finished emitting items.
  * <p>