Skip to content

Commit 2f3968d

Browse files
Remove Bad Filter Logic
This code was accidentally committed during exploration of groupBy/subscribeOn.
1 parent cec2bfd commit 2f3968d

File tree

1 file changed

+0
-14
lines changed

1 file changed

+0
-14
lines changed

rxjava-core/src/main/java/rx/operators/OperatorFilter.java

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -52,20 +52,6 @@ public void onNext(T value) {
5252
try {
5353
if (predicate.call(value)) {
5454
child.onNext(value);
55-
} else {
56-
/*
57-
* Special casing of GroupedObservable since GroupedObservable ***MUST*** be subscribed to
58-
* otherwise it will block the GroupBy operator.
59-
*
60-
* See https://github.com/Netflix/RxJava/issues/844
61-
*/
62-
if (value instanceof GroupedObservable) {
63-
System.out.println("value is GroupedObservable");
64-
@SuppressWarnings("rawtypes")
65-
GroupedObservable go = (GroupedObservable) value;
66-
System.out.println("********* unsubscribe from go");
67-
go.take(0).subscribe();
68-
}
6955
}
7056
} catch (Throwable ex) {
7157
child.onError(ex);

0 commit comments

Comments
 (0)