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

Packages that use BiPredicate

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.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.util

Uses of BiPredicate in io.reactivex.rxjava3.core

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

Modifier and Type	Method	Description
@NonNull Single<java.lang.Boolean>	Single.contains(@NonNull java.lang.Object item, @NonNull BiPredicate<java.lang.Object,java.lang.Object> comparer)	Signals true if the current Single signals a success value that is equal with the value provided by calling a BiPredicate.
@NonNull Flowable<T>	Flowable.distinctUntilChanged(@NonNull BiPredicate<? super @NonNull T,? super @NonNull T> comparer)	Returns a Flowable that emits all items emitted by the current Flowable that are distinct from their immediate predecessors when compared with each other via the provided comparator function.
@NonNull Observable<T>	Observable.distinctUntilChanged(@NonNull BiPredicate<? super @NonNull T,? super @NonNull T> comparer)	Returns an Observable that emits all items emitted by the current Observable that are distinct from their immediate predecessors when compared with each other via the provided comparator function.
@NonNull Completable	Completable.retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)	Returns a Completable that retries this Completable in case of an error as long as the predicate returns true.
@NonNull Flowable<T>	Flowable.retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)	Returns a Flowable that mirrors the current Flowable, resubscribing to it if it calls onError and the predicate returns true for that specific exception and retry count.
@NonNull Maybe<T>	Maybe.retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)	Returns a Maybe that mirrors the current Maybe, resubscribing to it if it calls onError and the predicate returns true for that specific exception and retry count.
@NonNull Observable<T>	Observable.retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)	Returns an Observable that mirrors the current Observable, resubscribing to it if it calls onError and the predicate returns true for that specific exception and retry count.
@NonNull Single<T>	Single.retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)	Re-subscribe to the current Single if the given predicate returns true when the Single fails with an onError.
static <@NonNull T> @NonNull Single<java.lang.Boolean>	Flowable.sequenceEqual(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1, @NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T,? super @NonNull T> isEqual)	Returns a Single that emits a Boolean value that indicates whether two Publisher sequences are the same by comparing the items emitted by each Publisher pairwise based on the results of a specified equality function.
static <@NonNull T> @NonNull Single<java.lang.Boolean>	Flowable.sequenceEqual(@NonNull org.reactivestreams.Publisher<? extends @NonNull T> source1, @NonNull org.reactivestreams.Publisher<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T,? super @NonNull T> isEqual, int bufferSize)	Returns a Single that emits a Boolean value that indicates whether two Publisher sequences are the same by comparing the items emitted by each Publisher pairwise based on the results of a specified equality function.
static <@NonNull T> @NonNull Single<java.lang.Boolean>	Maybe.sequenceEqual(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T,? super @NonNull T> isEqual)	Returns a Single that emits a Boolean value that indicates whether two MaybeSources are the same by comparing the items emitted by each MaybeSource pairwise based on the results of a specified equality function.
static <@NonNull T> @NonNull Single<java.lang.Boolean>	Observable.sequenceEqual(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T,? super @NonNull T> isEqual)	Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified equality function.
static <@NonNull T> @NonNull Single<java.lang.Boolean>	Observable.sequenceEqual(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T,? super @NonNull T> isEqual, int bufferSize)	Returns a Single that emits a Boolean value that indicates whether two ObservableSource sequences are the same by comparing the items emitted by each ObservableSource pairwise based on the results of a specified equality function.

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

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

Modifier and Type	Class	Description
(package private) static class	ObjectHelper.BiObjectPredicate

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

Modifier and Type	Field	Description
(package private) static BiPredicate<java.lang.Object,java.lang.Object>	ObjectHelper.EQUALS

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

Modifier and Type	Method	Description
static <T> BiPredicate<T,T>	ObjectHelper.equalsPredicate()	Returns a BiPredicate that compares its parameters via Objects.equals().

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

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

Modifier and Type	Field	Description
(package private) BiPredicate<? super K,? super K>	FlowableDistinctUntilChanged.comparer
(package private) BiPredicate<? super K,? super K>	FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber.comparer
(package private) BiPredicate<? super K,? super K>	FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber.comparer
(package private) BiPredicate<? super T,? super T>	FlowableSequenceEqual.comparer
(package private) BiPredicate<? super T,? super T>	FlowableSequenceEqual.EqualCoordinator.comparer
(package private) BiPredicate<? super T,? super T>	FlowableSequenceEqualSingle.comparer
(package private) BiPredicate<? super T,? super T>	FlowableSequenceEqualSingle.EqualCoordinator.comparer
(package private) BiPredicate<? super java.lang.Integer,? super java.lang.Throwable>	FlowableRetryBiPredicate.predicate
(package private) BiPredicate<? super java.lang.Integer,? super java.lang.Throwable>	FlowableRetryBiPredicate.RetryBiSubscriber.predicate

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

Constructor	Description
DistinctUntilChangedConditionalSubscriber(ConditionalSubscriber<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
DistinctUntilChangedSubscriber(org.reactivestreams.Subscriber<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
EqualCoordinator(org.reactivestreams.Subscriber<? super java.lang.Boolean> actual, int prefetch, BiPredicate<? super T,? super T> comparer)
EqualCoordinator(SingleObserver<? super java.lang.Boolean> actual, int prefetch, BiPredicate<? super T,? super T> comparer)
FlowableDistinctUntilChanged(Flowable<T> source, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
FlowableRetryBiPredicate(Flowable<T> source, BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
FlowableSequenceEqual(org.reactivestreams.Publisher<? extends T> first, org.reactivestreams.Publisher<? extends T> second, BiPredicate<? super T,? super T> comparer, int prefetch)
FlowableSequenceEqualSingle(org.reactivestreams.Publisher<? extends T> first, org.reactivestreams.Publisher<? extends T> second, BiPredicate<? super T,? super T> comparer, int prefetch)
RetryBiSubscriber(org.reactivestreams.Subscriber<? super T> actual, BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate, SubscriptionArbiter sa, org.reactivestreams.Publisher<? extends T> source)

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

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

Modifier and Type	Field	Description
(package private) BiPredicate<? super T,? super T>	MaybeEqualSingle.EqualCoordinator.isEqual
(package private) BiPredicate<? super T,? super T>	MaybeEqualSingle.isEqual

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

Constructor	Description
EqualCoordinator(SingleObserver<? super java.lang.Boolean> actual, BiPredicate<? super T,? super T> isEqual)
MaybeEqualSingle(MaybeSource<? extends T> source1, MaybeSource<? extends T> source2, BiPredicate<? super T,? super T> isEqual)

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

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

Modifier and Type	Field	Description
(package private) BiPredicate<? super K,? super K>	ObservableDistinctUntilChanged.comparer
(package private) BiPredicate<? super K,? super K>	ObservableDistinctUntilChanged.DistinctUntilChangedObserver.comparer
(package private) BiPredicate<? super T,? super T>	ObservableSequenceEqual.comparer
(package private) BiPredicate<? super T,? super T>	ObservableSequenceEqual.EqualCoordinator.comparer
(package private) BiPredicate<? super T,? super T>	ObservableSequenceEqualSingle.comparer
(package private) BiPredicate<? super T,? super T>	ObservableSequenceEqualSingle.EqualCoordinator.comparer
(package private) BiPredicate<? super java.lang.Integer,? super java.lang.Throwable>	ObservableRetryBiPredicate.predicate
(package private) BiPredicate<? super java.lang.Integer,? super java.lang.Throwable>	ObservableRetryBiPredicate.RetryBiObserver.predicate

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

Constructor	Description
DistinctUntilChangedObserver(Observer<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
EqualCoordinator(Observer<? super java.lang.Boolean> actual, int bufferSize, ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T,? super T> comparer)
EqualCoordinator(SingleObserver<? super java.lang.Boolean> actual, int bufferSize, ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T,? super T> comparer)
ObservableDistinctUntilChanged(ObservableSource<T> source, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
ObservableRetryBiPredicate(Observable<T> source, BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
ObservableSequenceEqual(ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T,? super T> comparer, int bufferSize)
ObservableSequenceEqualSingle(ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T,? super T> comparer, int bufferSize)
RetryBiObserver(Observer<? super T> actual, BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate, SequentialDisposable sa, ObservableSource<? extends T> source)

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

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

Modifier and Type	Field	Description
(package private) BiPredicate<java.lang.Object,java.lang.Object>	SingleContains.comparer

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

Constructor	Description
SingleContains(SingleSource<T> source, java.lang.Object value, BiPredicate<java.lang.Object,java.lang.Object> comparer)

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

Methods in io.reactivex.rxjava3.internal.util with parameters of type BiPredicate

Modifier and Type	Method	Description
<S> void	AppendOnlyLinkedArrayList.forEachWhile(S state, BiPredicate<? super S,? super T> consumer)	Loops over all elements of the array until a null element is encountered or the given predicate returns true.