TakeUntilPredicate<TSource> sealed class TakeUntilPredicate<TSource> : Producer<TSource, TakeUntilPredicateObserver<TSource>> Relays items to the downstream until the predicate returns true. Documentation Code public TakeUntilPredicate(IObservable<TSource> source, Func<TSource, bool> stopPredicate)