Call complete on take/takeWhile observables once the predicate is true.

Author: thegeez

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

@@ -147,6 +147,7 @@ public void onNext(T args) {
                 if (predicate.call(args, counter.getAndIncrement())) {
                     observer.onNext(args);
                 } else {
+                    observer.onCompleted();
                     // this will work if the sequence is asynchronous, it will have no effect on a synchronous observable
                     subscription.unsubscribe();
                 }