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

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

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

Modifier	Constructor	Description
	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)

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

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

Modifier	Constructor	Description
	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

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

Modifier	Constructor	Description
	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)

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

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.