Merge pull request #887 from benjchristensen/filter-cleanup

Remove Bad Filter Logic
ReactiveX · Feb 17, 2014 · b8b28e4 · b8b28e4
2 parents cec2bfd + 2f3968d
commit b8b28e4
Showing 1 changed file with 0 additions and 14 deletions.
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);