Move GroupedObservable to rx.observables

ReactiveX · Mar 12, 2013 · 571a970 · 571a970
1 parent 5d18471
commit 571a970
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java
@@ -29,6 +29,7 @@
 import org.mockito.Mockito;
 import org.mockito.MockitoAnnotations;
 
+import rx.observables.GroupedObservable;
 import rx.operators.*;
 import rx.plugins.RxJavaErrorHandler;
 import rx.plugins.RxJavaPlugins;

diff --git a/...e/src/main/java/rx/GroupedObservable.java → ...ava/rx/observables/GroupedObservable.java b/...e/src/main/java/rx/GroupedObservable.java → ...ava/rx/observables/GroupedObservable.java
@@ -13,8 +13,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx;
+package rx.observables;
 
+import rx.Observable;
+import rx.Observer;
+import rx.Subscription;
 import rx.util.functions.Func1;
 
 /**
@@ -29,7 +32,7 @@ public class GroupedObservable<K, T> extends Observable<T> {
     private final K key;
 
     public GroupedObservable(K key, Func1<Observer<T>, Subscription> onSubscribe) {
-        super(onSubscribe, true);
+        super(onSubscribe);
         this.key = key;
     }
 

diff --git a/rxjava-core/src/main/java/rx/operators/OperatorGroupBy.java b/rxjava-core/src/main/java/rx/operators/OperatorGroupBy.java
@@ -16,10 +16,10 @@
 package rx.operators;
 
 import org.junit.Test;
-import rx.GroupedObservable;
 import rx.Observable;
 import rx.Observer;
 import rx.Subscription;
+import rx.observables.GroupedObservable;
 import rx.util.functions.Func1;
 import rx.util.functions.Functions;