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.
io.reactivex.rxjava3.processors	Classes representing so-called hot backpressure-aware sources, aka processors, that implement the FlowableProcessor class, the Reactive Streams Processor interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive Streams Publisher.
io.reactivex.rxjava3.subjects	Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.

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

Classes in io.reactivex.rxjava3.internal.functions that implement Predicate

Modifier and Type	Class	Description
(package private) static final class	Functions.BooleanSupplierPredicateReverse<T>
(package private) static final class	Functions.ClassFilter<T,U>
(package private) static final class	Functions.EqualsPredicate<T>
(package private) static final class	Functions.FalsePredicate
(package private) static final class	Functions.TruePredicate

Fields in io.reactivex.rxjava3.internal.functions declared as Predicate

Modifier and Type	Field	Description
(package private) static final Predicate<Object>	Functions.ALWAYS_FALSE
(package private) static final Predicate<Object>	Functions.ALWAYS_TRUE

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

Fields in io.reactivex.rxjava3.internal.observers declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super T>	ForEachWhileObserver.onNext

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

Fields in io.reactivex.rxjava3.internal.operators.completable declared as Predicate

Modifier and Type	Field	Description
private final Predicate<? super Throwable>	CompletableOnErrorComplete.OnError.predicate
(package private) final Predicate<? super Throwable>	CompletableOnErrorComplete.predicate

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

Modifier	Constructor	Description
	CompletableOnErrorComplete(CompletableSource source, Predicate<? super Throwable> predicate)
(package private)	OnError(CompletableObserver observer, Predicate<? super Throwable> predicate)

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

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super T>	FlowableFilter.FilterConditionalSubscriber.filter
(package private) final Predicate<? super T>	FlowableFilter.FilterSubscriber.filter
(package private) final Predicate<? super T>	FlowableAll.AllSubscriber.predicate
(package private) final Predicate<? super T>	FlowableAll.predicate
(package private) final Predicate<? super T>	FlowableAllSingle.AllSubscriber.predicate
(package private) final Predicate<? super T>	FlowableAllSingle.predicate
(package private) final Predicate<? super T>	FlowableAny.AnySubscriber.predicate
(package private) final Predicate<? super T>	FlowableAny.predicate
(package private) final Predicate<? super T>	FlowableAnySingle.AnySubscriber.predicate
(package private) final Predicate<? super T>	FlowableAnySingle.predicate
(package private) final Predicate<? super T>	FlowableFilter.predicate
(package private) final Predicate<? super Throwable>	FlowableOnErrorComplete.OnErrorCompleteSubscriber.predicate
(package private) final Predicate<? super Throwable>	FlowableOnErrorComplete.predicate
(package private) final Predicate<? super Throwable>	FlowableRetryPredicate.predicate
(package private) final Predicate<? super Throwable>	FlowableRetryPredicate.RetrySubscriber.predicate
(package private) final Predicate<? super T>	FlowableSkipWhile.predicate
(package private) final Predicate<? super T>	FlowableSkipWhile.SkipWhileSubscriber.predicate
(package private) final Predicate<? super T>	FlowableTakeUntilPredicate.InnerSubscriber.predicate
(package private) final Predicate<? super T>	FlowableTakeUntilPredicate.predicate
(package private) final Predicate<? super T>	FlowableTakeWhile.predicate
(package private) final Predicate<? super T>	FlowableTakeWhile.TakeWhileSubscriber.predicate

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

Modifier	Constructor	Description
(package private)	AllSubscriber(org.reactivestreams.Subscriber<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AllSubscriber(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AnySubscriber(org.reactivestreams.Subscriber<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AnySubscriber(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	FilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> filter)
(package private)	FilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> filter)
	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)
(package private)	InnerSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
	OnErrorCompleteSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super Throwable> predicate)
(package private)	RetrySubscriber(org.reactivestreams.Subscriber<? super T> actual, long count, Predicate<? super Throwable> predicate, SubscriptionArbiter sa, org.reactivestreams.Publisher<? extends T> source)
(package private)	SkipWhileSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
(package private)	TakeWhileSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)

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

Fields in io.reactivex.rxjava3.internal.operators.maybe declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super T>	MaybeFilter.FilterMaybeObserver.predicate
(package private) final Predicate<? super T>	MaybeFilter.predicate
(package private) final Predicate<? super T>	MaybeFilterSingle.FilterMaybeObserver.predicate
(package private) final Predicate<? super T>	MaybeFilterSingle.predicate
(package private) final Predicate<? super Throwable>	MaybeOnErrorComplete.OnErrorCompleteMultiObserver.predicate
(package private) final Predicate<? super Throwable>	MaybeOnErrorComplete.predicate

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

Modifier	Constructor	Description
(package private)	FilterMaybeObserver(MaybeObserver<? super T> actual, Predicate<? super T> predicate)
(package private)	FilterMaybeObserver(MaybeObserver<? super T> actual, Predicate<? super T> predicate)
	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

Fields in io.reactivex.rxjava3.internal.operators.observable declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super T>	ObservableFilter.FilterObserver.filter
(package private) final Predicate<? super T>	ObservableAll.AllObserver.predicate
(package private) final Predicate<? super T>	ObservableAll.predicate
(package private) final Predicate<? super T>	ObservableAllSingle.AllObserver.predicate
(package private) final Predicate<? super T>	ObservableAllSingle.predicate
(package private) final Predicate<? super T>	ObservableAny.AnyObserver.predicate
(package private) final Predicate<? super T>	ObservableAny.predicate
(package private) final Predicate<? super T>	ObservableAnySingle.AnyObserver.predicate
(package private) final Predicate<? super T>	ObservableAnySingle.predicate
(package private) final Predicate<? super T>	ObservableFilter.predicate
(package private) final Predicate<? super Throwable>	ObservableOnErrorComplete.OnErrorCompleteObserver.predicate
(package private) final Predicate<? super Throwable>	ObservableOnErrorComplete.predicate
(package private) final Predicate<? super Throwable>	ObservableRetryPredicate.predicate
(package private) final Predicate<? super Throwable>	ObservableRetryPredicate.RepeatObserver.predicate
(package private) final Predicate<? super T>	ObservableSkipWhile.predicate
(package private) final Predicate<? super T>	ObservableSkipWhile.SkipWhileObserver.predicate
(package private) final Predicate<? super T>	ObservableTakeUntilPredicate.predicate
(package private) final Predicate<? super T>	ObservableTakeUntilPredicate.TakeUntilPredicateObserver.predicate
(package private) final Predicate<? super T>	ObservableTakeWhile.predicate
(package private) final Predicate<? super T>	ObservableTakeWhile.TakeWhileObserver.predicate

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

Modifier	Constructor	Description
(package private)	AllObserver(Observer<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AllObserver(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AnyObserver(Observer<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AnyObserver(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	FilterObserver(Observer<? super T> actual, Predicate<? super T> filter)
	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)
(package private)	RepeatObserver(Observer<? super T> actual, long count, Predicate<? super Throwable> predicate, SequentialDisposable sa, ObservableSource<? extends T> source)
(package private)	SkipWhileObserver(Observer<? super T> actual, Predicate<? super T> predicate)
(package private)	TakeUntilPredicateObserver(Observer<? super T> downstream, Predicate<? super T> predicate)
(package private)	TakeWhileObserver(Observer<? super T> actual, Predicate<? super T> predicate)

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

Fields in io.reactivex.rxjava3.internal.operators.parallel declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super T>	ParallelFilter.BaseFilterSubscriber.predicate
(package private) final Predicate<? super T>	ParallelFilter.predicate
(package private) final Predicate<? super T>	ParallelFilterTry.BaseFilterSubscriber.predicate
(package private) final Predicate<? super T>	ParallelFilterTry.predicate

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

Modifier	Constructor	Description
(package private)	BaseFilterSubscriber(Predicate<? super T> predicate)
(package private)	BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
	ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate)
(package private)	ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate)
(package private)	ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
(package private)	ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
(package private)	ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler)
	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

Fields in io.reactivex.rxjava3.internal.operators.single declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super Throwable>	SingleOnErrorComplete.predicate

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

Fields in io.reactivex.rxjava3.internal.subscribers declared as Predicate

Modifier and Type	Field	Description
(package private) final Predicate<? super T>	ForEachWhileSubscriber.onNext

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.
private U	BaseTestConsumer.assertError(@NonNull Predicate<Throwable> errorPredicate, boolean exact)
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.

Uses of Predicate in io.reactivex.rxjava3.processors

Classes in io.reactivex.rxjava3.processors that implement Predicate

Modifier and Type	Class	Description
(package private) static final class	BehaviorProcessor.BehaviorSubscription<T>

Uses of Predicate in io.reactivex.rxjava3.subjects

Classes in io.reactivex.rxjava3.subjects that implement Predicate

Modifier and Type	Class	Description
(package private) static final class	BehaviorSubject.BehaviorDisposable<T>
(package private) final class	SerializedSubject<T>	Serializes calls to the Observer methods.