Bind implementation of Merge

- it’s working … but I can’t figure out the co/contra-variance for the generics! anyone have ideas?

Author: benjchristensen

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

@@ -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?!
     }
 
     /**

rxjava-core/src/main/java/rx/operators/OperationMerge.java

@@ -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>