Add unsubscribe

ReactiveX · Apr 29, 2014 · b7af5c9 · b7af5c9
1 parent dda2351
commit b7af5c9
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rxjava-core/src/main/java/rx/operators/OperatorTakeWhile.java b/rxjava-core/src/main/java/rx/operators/OperatorTakeWhile.java
@@ -56,12 +56,14 @@ public void onNext(T args) {
                     isSelected = predicate.call(args, counter++);
                 } catch (Throwable e) {
                     subscriber.onError(e);
+                    unsubscribe();
                     return;
                 }
                 if (isSelected) {
                     subscriber.onNext(args);
                 } else {
                     subscriber.onCompleted();
+                    unsubscribe();
                 }
             }