Class OperatorTakeUntilPredicate<T>

  • Type Parameters:
    T - the value type
    All Implemented Interfaces:
    Func1<Subscriber<? super T>,​Subscriber<? super T>>, Function, Observable.Operator<T,​T>

    public final class OperatorTakeUntilPredicate<T>
    extends java.lang.Object
    implements Observable.Operator<T,​T>
    Returns an Observable that emits items emitted by the source Observable until the provided predicate returns false

    • Field Detail

      • stopPredicate

        final Func1<? super T,​java.lang.Boolean> stopPredicate
    • Constructor Detail

      • OperatorTakeUntilPredicate

        public OperatorTakeUntilPredicate​(Func1<? super T,​java.lang.Boolean> stopPredicate)