OperatorGroupJoin

ReactiveX · Apr 25, 2014 · 79c07ee · 79c07ee
1 parent 95e0636
commit 79c07ee
Show file tree

Hide file tree

Showing 3 changed files with 147 additions and 121 deletions.
diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java
@@ -51,7 +51,7 @@
 import rx.operators.OperationDebounce;
 import rx.operators.OperationDelay;
 import rx.operators.OperationGroupByUntil;
-import rx.operators.OperationGroupJoin;
+import rx.operators.OperatorGroupJoin;
 import rx.operators.OperationInterval;
 import rx.operators.OperationJoin;
 import rx.operators.OperationMergeDelayError;
@@ -4108,7 +4108,7 @@ public final <TKey, TValue, TDuration> Observable<GroupedObservable<TKey, TValue
     public final <T2, D1, D2, R> Observable<R> groupJoin(Observable<T2> right, Func1<? super T, ? extends Observable<D1>> leftDuration,
             Func1<? super T2, ? extends Observable<D2>> rightDuration,
             Func2<? super T, ? super Observable<T2>, ? extends R> resultSelector) {
-        return create(new OperationGroupJoin<T, T2, D1, D2, R>(this, right, leftDuration, rightDuration, resultSelector));
+        return create(new OperatorGroupJoin<T, T2, D1, D2, R>(this, right, leftDuration, rightDuration, resultSelector));
     }
 
     /**