Class ObservableTakeUntilPredicate.TakeUntilPredicateObserver<T>