From 2f3968dbfda2dd88a52a5737931e4df606ba46d0 Mon Sep 17 00:00:00 2001 From: Ben Christensen Date: Mon, 17 Feb 2014 10:25:09 -0800 Subject: [PATCH] Remove Bad Filter Logic This code was accidentally committed during exploration of groupBy/subscribeOn. --- .../src/main/java/rx/operators/OperatorFilter.java | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/rxjava-core/src/main/java/rx/operators/OperatorFilter.java b/rxjava-core/src/main/java/rx/operators/OperatorFilter.java index 41b749dc75..a6e8850f2b 100644 --- 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);