Merge pull request #887 from benjchristensen/filter-cleanup

Remove Bad Filter Logic

Author: benjchristensen

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);