Uses of Interface
io.reactivex.rxjava3.functions.Predicate

Packages that use Predicate

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.functions
io.reactivex.rxjava3.internal.observers
io.reactivex.rxjava3.internal.operators.completable
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.subscribers
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.observers	Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestObserver that allows unit testing Observable-, Single-, Maybe- and Completable-based flows.
io.reactivex.rxjava3.parallel	Contains the base type ParallelFlowable, a sub-DSL for working with Flowable sequences in parallel.

Uses of Predicate in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core with parameters of type Predicate

Modifier and Type	Method	Description
final @NonNull Single<Boolean>	Flowable.all(@NonNull Predicate<? super @NonNull T> predicate)	Returns a Single that emits a Boolean that indicates whether all of the items emitted by the current Flowable satisfy a condition.
final @NonNull Single<Boolean>	Observable.all(@NonNull Predicate<? super @NonNull T> predicate)	Returns a Single that emits a Boolean that indicates whether all of the items emitted by the current Observable satisfy a condition.
final @NonNull Single<Boolean>	Flowable.any(@NonNull Predicate<? super @NonNull T> predicate)	Returns a Single that emits true if any item emitted by the current Flowable satisfies a specified condition, otherwise false.
final @NonNull Single<Boolean>	Observable.any(@NonNull Predicate<? super @NonNull T> predicate)	Returns a Single that emits true if any item emitted by the current Observable satisfies a specified condition, otherwise false.
final @NonNull Flowable<T>	Flowable.filter(@NonNull Predicate<? super @NonNull T> predicate)	Filters items emitted by the current Flowable by only emitting those that satisfy a specified predicate.
final @NonNull Maybe<T>	Maybe.filter(@NonNull Predicate<? super @NonNull T> predicate)	Filters the success item of the Maybe via a predicate function and emitting it if the predicate returns true, completing otherwise.
final @NonNull Observable<T>	Observable.filter(@NonNull Predicate<? super @NonNull T> predicate)	Filters items emitted by the current Observable by only emitting those that satisfy a specified Predicate.
final @NonNull Maybe<T>	Single.filter(@NonNull Predicate<? super @NonNull T> predicate)	Filters the success item of the Single via a predicate function and emitting it if the predicate returns true, completing otherwise.
final @NonNull Disposable	Flowable.forEachWhile(@NonNull Predicate<? super @NonNull T> onNext)	Subscribes to the current Flowable and receives notifications for each element until the onNext Predicate returns false.
final @NonNull Disposable	Flowable.forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError)	Subscribes to the current Flowable and receives notifications for each element and error events until the onNext Predicate returns false.
final @NonNull Disposable	Flowable.forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete)	Subscribes to the current Flowable and receives notifications for each element and the terminal events until the onNext Predicate returns false.
final @NonNull Disposable	Observable.forEachWhile(@NonNull Predicate<? super @NonNull T> onNext)	Subscribes to the ObservableSource and calls a Predicate for each item of the current Observable, on its emission thread, until the predicate returns false.
final @NonNull Disposable	Observable.forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError)	Subscribes to the ObservableSource and calls a Predicate for each item or a Consumer with the error of the current Observable, on their original emission threads, until the predicate returns false.
final @NonNull Disposable	Observable.forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete)	Subscribes to the ObservableSource and calls a Predicate for each item, a Consumer with the error or an Action upon completion of the current Observable, on their original emission threads, until the predicate returns false.
final @NonNull Completable	Completable.onErrorComplete(@NonNull Predicate<? super Throwable> predicate)	Returns a Completable instance that if this Completable emits an error and the Predicate returns true, it will emit an onComplete and swallow the Throwable.
final @NonNull Flowable<T>	Flowable.onErrorComplete(@NonNull Predicate<? super Throwable> predicate)	Returns a Flowable instance that if the current Flowable emits an error and the predicate returns true, it will emit an onComplete and swallow the throwable.
final @NonNull Maybe<T>	Maybe.onErrorComplete(@NonNull Predicate<? super Throwable> predicate)	Returns a Maybe instance that if this Maybe emits an error and the predicate returns true, it will emit an onComplete and swallow the throwable.
final @NonNull Observable<T>	Observable.onErrorComplete(@NonNull Predicate<? super Throwable> predicate)	Returns an Observable instance that if the current Observable emits an error and the predicate returns true, it will emit an onComplete and swallow the throwable.
final @NonNull Maybe<T>	Single.onErrorComplete(@NonNull Predicate<? super Throwable> predicate)	Returns a Maybe instance that if this Single emits an error and the predicate returns true, it will emit an onComplete and swallow the throwable.
final @NonNull Completable	Completable.retry(long times, @NonNull Predicate<? super Throwable> predicate)	Returns a Completable that when this Completable emits an error, retries at most times or until the predicate returns false, whichever happens first and emitting the last error.
final @NonNull Completable	Completable.retry(@NonNull Predicate<? super Throwable> predicate)	Returns a Completable that when this Completable emits an error, calls the given predicate with the latest Throwable to decide whether to resubscribe to the upstream or not.
final @NonNull Flowable<T>	Flowable.retry(long times, @NonNull Predicate<@NonNull ? super Throwable> predicate)	Retries at most times or until the predicate returns false, whichever happens first.
final @NonNull Flowable<T>	Flowable.retry(@NonNull Predicate<@NonNull ? super Throwable> predicate)	Retries the current Flowable if the predicate returns true.
final @NonNull Maybe<T>	Maybe.retry(long times, @NonNull Predicate<? super Throwable> predicate)	Retries at most times or until the predicate returns false, whichever happens first.
final @NonNull Maybe<T>	Maybe.retry(@NonNull Predicate<? super Throwable> predicate)	Retries the current Maybe if it fails and the predicate returns true.
final @NonNull Observable<T>	Observable.retry(long times, @NonNull Predicate<? super Throwable> predicate)	Retries at most times or until the predicate returns false, whichever happens first.
final @NonNull Observable<T>	Observable.retry(@NonNull Predicate<? super Throwable> predicate)	Retries the current Observable if the predicate returns true.
final @NonNull Single<T>	Single.retry(long times, @NonNull Predicate<? super Throwable> predicate)	Repeatedly re-subscribe at most times or until the predicate returns false, whichever happens first if it fails with an onError.
final @NonNull Single<T>	Single.retry(@NonNull Predicate<? super Throwable> predicate)	Re-subscribe to the current Single if the given predicate returns true when the Single fails with an onError.
final @NonNull Flowable<T>	Flowable.skipWhile(@NonNull Predicate<? super @NonNull T> predicate)	Returns a Flowable that skips all items emitted by the current Flowable as long as a specified condition holds true, but emits all further source items as soon as the condition becomes false.
final @NonNull Observable<T>	Observable.skipWhile(@NonNull Predicate<? super @NonNull T> predicate)	Returns an Observable that skips all items emitted by the current Observable as long as a specified condition holds true, but emits all further source items as soon as the condition becomes false.
final @NonNull Flowable<T>	Flowable.takeUntil(@NonNull Predicate<? super @NonNull T> stopPredicate)	Returns a Flowable that emits items emitted by the current Flowable, checks the specified predicate for each item, and then completes when the condition is satisfied.
final @NonNull Observable<T>	Observable.takeUntil(@NonNull Predicate<? super @NonNull T> stopPredicate)	Returns an Observable that emits items emitted by the current Observable, checks the specified predicate for each item, and then completes when the condition is satisfied.
final @NonNull Flowable<T>	Flowable.takeWhile(@NonNull Predicate<? super @NonNull T> predicate)	Returns a Flowable that emits items emitted by the current Flowable so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied.
final @NonNull Observable<T>	Observable.takeWhile(@NonNull Predicate<? super @NonNull T> predicate)	Returns an Observable that emits items emitted by the current Observable so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied.

Uses of Predicate in io.reactivex.rxjava3.internal.functions

Methods in io.reactivex.rxjava3.internal.functions that return Predicate

Modifier and Type	Method	Description
static <T> @NonNull Predicate<T>	Functions.alwaysFalse()
static <T> @NonNull Predicate<T>	Functions.alwaysTrue()
static <T> Predicate<T>	Functions.equalsWith(T value)
static <T,U> Predicate<T>	Functions.isInstanceOf(Class<U> clazz)
static <T> Predicate<T>	Functions.predicateReverseFor(BooleanSupplier supplier)

Uses of Predicate in io.reactivex.rxjava3.internal.observers

Constructors in io.reactivex.rxjava3.internal.observers with parameters of type Predicate

Modifier	Constructor	Description
	ForEachWhileObserver(Predicate<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)

Uses of Predicate in io.reactivex.rxjava3.internal.operators.completable

Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type Predicate

Modifier	Constructor	Description
	CompletableOnErrorComplete(CompletableSource source, Predicate<? super Throwable> predicate)

Uses of Predicate in io.reactivex.rxjava3.internal.operators.flowable

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Predicate

Modifier	Constructor	Description
	FlowableAll(Flowable<T> source, Predicate<? super T> predicate)
	FlowableAllSingle(Flowable<T> source, Predicate<? super T> predicate)
	FlowableAny(Flowable<T> source, Predicate<? super T> predicate)
	FlowableAnySingle(Flowable<T> source, Predicate<? super T> predicate)
	FlowableFilter(Flowable<T> source, Predicate<? super T> predicate)
	FlowableOnErrorComplete(Flowable<T> source, Predicate<? super Throwable> predicate)
	FlowableRetryPredicate(Flowable<T> source, long count, Predicate<? super Throwable> predicate)
	FlowableSkipWhile(Flowable<T> source, Predicate<? super T> predicate)
	FlowableTakeUntilPredicate(Flowable<T> source, Predicate<? super T> predicate)
	FlowableTakeWhile(Flowable<T> source, Predicate<? super T> predicate)
	OnErrorCompleteSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super Throwable> predicate)

Uses of Predicate in io.reactivex.rxjava3.internal.operators.maybe

Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type Predicate

Modifier	Constructor	Description
	MaybeFilter(MaybeSource<T> source, Predicate<? super T> predicate)
	MaybeFilterSingle(SingleSource<T> source, Predicate<? super T> predicate)
	MaybeOnErrorComplete(MaybeSource<T> source, Predicate<? super Throwable> predicate)
	OnErrorCompleteMultiObserver(MaybeObserver<? super T> actual, Predicate<? super Throwable> predicate)

Uses of Predicate in io.reactivex.rxjava3.internal.operators.observable

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Predicate

Modifier	Constructor	Description
	ObservableAll(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableAllSingle(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableAny(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableAnySingle(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableFilter(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableOnErrorComplete(ObservableSource<T> source, Predicate<? super Throwable> predicate)
	ObservableRetryPredicate(Observable<T> source, long count, Predicate<? super Throwable> predicate)
	ObservableSkipWhile(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableTakeUntilPredicate(ObservableSource<T> source, Predicate<? super T> predicate)
	ObservableTakeWhile(ObservableSource<T> source, Predicate<? super T> predicate)
	OnErrorCompleteObserver(Observer<? super T> actual, Predicate<? super Throwable> predicate)

Uses of Predicate in io.reactivex.rxjava3.internal.operators.parallel

Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Predicate

Modifier	Constructor	Description
	ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate)
	ParallelFilterTry(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)

Uses of Predicate in io.reactivex.rxjava3.internal.operators.single

Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type Predicate

Modifier	Constructor	Description
	SingleOnErrorComplete(Single<T> source, Predicate<? super Throwable> predicate)

Uses of Predicate in io.reactivex.rxjava3.internal.subscribers

Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type Predicate

Modifier	Constructor	Description
	ForEachWhileSubscriber(Predicate<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)

Uses of Predicate in io.reactivex.rxjava3.internal.util

Subinterfaces of Predicate in io.reactivex.rxjava3.internal.util

Modifier and Type	Interface	Description
static interface	AppendOnlyLinkedArrayList.NonThrowingPredicate<T>	Predicate interface suppressing the exception.

Uses of Predicate in io.reactivex.rxjava3.observers

Methods in io.reactivex.rxjava3.observers with parameters of type Predicate

Modifier and Type	Method	Description
final U	BaseTestConsumer.assertError(@NonNull Predicate<Throwable> errorPredicate)	Asserts that this TestObserver/TestSubscriber received exactly one onError event for which the provided predicate returns true.
final U	BaseTestConsumer.assertValue(@NonNull Predicate<T> valuePredicate)	Asserts that this TestObserver/TestSubscriber received exactly one onNext value for which the provided predicate returns true.
final U	BaseTestConsumer.assertValueAt(int index, @NonNull Predicate<T> valuePredicate)	Asserts that this TestObserver/TestSubscriber received an onNext value at the given index for the provided predicate returns true.

Uses of Predicate in io.reactivex.rxjava3.parallel

Methods in io.reactivex.rxjava3.parallel with parameters of type Predicate

Modifier and Type	Method	Description
final @NonNull ParallelFlowable<T>	ParallelFlowable.filter(@NonNull Predicate<? super @NonNull T> predicate)	Filters the source values on each 'rail'.
final @NonNull ParallelFlowable<T>	ParallelFlowable.filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)	Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.
final @NonNull ParallelFlowable<T>	ParallelFlowable.filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull ParallelFailureHandling errorHandler)	Filters the source values on each 'rail' and handles errors based on the given ParallelFailureHandling enumeration value.