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
final @NonNull Single<Boolean>	Single.contains(@NonNull Object item, @NonNull BiPredicate<Object,Object> comparer)	Signals true if the current Single signals a success value that is equal with the value provided by calling a BiPredicate.
final @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.
final @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.
final @NonNull Completable	Completable.retry(@NonNull BiPredicate<? super Integer,? super Throwable> predicate)	Returns a Completable that retries this Completable in case of an error as long as the predicate returns true.
final @NonNull Flowable<T>	Flowable.retry(@NonNull BiPredicate<@NonNull ? super Integer,@NonNull ? super 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.
final @NonNull Maybe<T>	Maybe.retry(@NonNull BiPredicate<? super Integer,? super 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.
final @NonNull Observable<T>	Observable.retry(@NonNull BiPredicate<? super Integer,? super 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.
final @NonNull Single<T>	Single.retry(@NonNull BiPredicate<? super Integer,? super 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<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<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<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<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<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 final class	ObjectHelper.BiObjectPredicate

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

Modifier and Type	Field	Description
(package private) static final BiPredicate<Object,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) final BiPredicate<? super K,? super K>	FlowableDistinctUntilChanged.comparer
(package private) final BiPredicate<? super K,? super K>	FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber.comparer
(package private) final BiPredicate<? super K,? super K>	FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber.comparer
(package private) final BiPredicate<? super T,? super T>	FlowableSequenceEqual.comparer
(package private) final BiPredicate<? super T,? super T>	FlowableSequenceEqual.EqualCoordinator.comparer
(package private) final BiPredicate<? super T,? super T>	FlowableSequenceEqualSingle.comparer
(package private) final BiPredicate<? super T,? super T>	FlowableSequenceEqualSingle.EqualCoordinator.comparer
(package private) final BiPredicate<? super Integer,? super Throwable>	FlowableRetryBiPredicate.predicate
(package private) final BiPredicate<? super Integer,? super Throwable>	FlowableRetryBiPredicate.RetryBiSubscriber.predicate

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

Modifier	Constructor	Description
(package private)	DistinctUntilChangedConditionalSubscriber(ConditionalSubscriber<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
(package private)	DistinctUntilChangedSubscriber(org.reactivestreams.Subscriber<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
(package private)	EqualCoordinator(org.reactivestreams.Subscriber<? super Boolean> actual, int prefetch, BiPredicate<? super T,? super T> comparer)
(package private)	EqualCoordinator(SingleObserver<? super 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 Integer,? super 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)
(package private)	RetryBiSubscriber(org.reactivestreams.Subscriber<? super T> actual, BiPredicate<? super Integer,? super 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) final BiPredicate<? super T,? super T>	MaybeEqualSingle.EqualCoordinator.isEqual
(package private) final BiPredicate<? super T,? super T>	MaybeEqualSingle.isEqual

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

Modifier	Constructor	Description
(package private)	EqualCoordinator(SingleObserver<? super 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) final BiPredicate<? super K,? super K>	ObservableDistinctUntilChanged.comparer
(package private) final BiPredicate<? super K,? super K>	ObservableDistinctUntilChanged.DistinctUntilChangedObserver.comparer
(package private) final BiPredicate<? super T,? super T>	ObservableSequenceEqual.comparer
(package private) final BiPredicate<? super T,? super T>	ObservableSequenceEqual.EqualCoordinator.comparer
(package private) final BiPredicate<? super T,? super T>	ObservableSequenceEqualSingle.comparer
(package private) final BiPredicate<? super T,? super T>	ObservableSequenceEqualSingle.EqualCoordinator.comparer
(package private) final BiPredicate<? super Integer,? super Throwable>	ObservableRetryBiPredicate.predicate
(package private) final BiPredicate<? super Integer,? super Throwable>	ObservableRetryBiPredicate.RetryBiObserver.predicate

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

Modifier	Constructor	Description
(package private)	DistinctUntilChangedObserver(Observer<? super T> actual, Function<? super T,K> keySelector, BiPredicate<? super K,? super K> comparer)
(package private)	EqualCoordinator(Observer<? super Boolean> actual, int bufferSize, ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T,? super T> comparer)
(package private)	EqualCoordinator(SingleObserver<? super 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 Integer,? super 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)
(package private)	RetryBiObserver(Observer<? super T> actual, BiPredicate<? super Integer,? super 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) final BiPredicate<Object,Object>	SingleContains.comparer

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

Modifier	Constructor	Description
	SingleContains(SingleSource<T> source, Object value, BiPredicate<Object,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.