Merge pull request ReactiveX#887 from benjchristensen/filter-cleanup

benjchristensen · benjchristensen · commit b8b28e4a2477 · 2014-02-17T10:25:34.000-08:00
Remove Bad Filter Logic
diff --git a/rxjava-core/src/main/java/rx/operators/OperatorFilter.java b/rxjava-core/src/main/java/rx/operators/OperatorFilter.java
@@ -52,20 +52,6 @@ public void onNext(T value) {
                 try {
                     if (predicate.call(value)) {
                         child.onNext(value);
-                    } else {
-                        /*
-                         * Special casing of GroupedObservable since GroupedObservable ***MUST*** be subscribed to
-                         * otherwise it will block the GroupBy operator. 
-                         * 
-                         * See https://github.com/Netflix/RxJava/issues/844
-                         */
-                        if (value instanceof GroupedObservable) {
-                            System.out.println("value is GroupedObservable");
-                            @SuppressWarnings("rawtypes")
-                            GroupedObservable go = (GroupedObservable) value;
-                            System.out.println("********* unsubscribe from go");
-                            go.take(0).subscribe();
-                        }
                     }
                 } catch (Throwable ex) {
                     child.onError(ex);
