takeWhile

open fun takeWhile(predicate: (T) -> Boolean): Observable<T>

open fun takeWhile(inclusive: Boolean, predicate: (T) -> Boolean): Observable<T>

Returns an observable that emits downstream up until the predicate returns false.