Uses of Interface
io.reactivex.rxjava3.functions.BiPredicate
Packages that use BiPredicate
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.-
Uses of BiPredicate in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type BiPredicateModifier and TypeMethodDescriptionSignalstrue
if the currentSingle
signals a success value that is equal with the value provided by calling aBiPredicate
.Flowable.distinctUntilChanged
(@NonNull BiPredicate<? super @NonNull T, ? super @NonNull T> comparer) Returns aFlowable
that emits all items emitted by the currentFlowable
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 anObservable
that emits all items emitted by the currentObservable
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 aCompletable
that retries thisCompletable
in case of an error as long as thepredicate
returnstrue
.Returns aFlowable
that mirrors the currentFlowable
, resubscribing to it if it callsonError
and the predicate returnstrue
for that specific exception and retry count.Maybe.retry
(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Returns aMaybe
that mirrors the currentMaybe
, resubscribing to it if it callsonError
and the predicate returnstrue
for that specific exception and retry count.final @NonNull Observable
<T> Observable.retry
(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Returns anObservable
that mirrors the currentObservable
, resubscribing to it if it callsonError
and the predicate returnstrue
for that specific exception and retry count.Single.retry
(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Re-subscribe to the currentSingle
if the given predicate returnstrue
when theSingle
fails with anonError
.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) 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) Maybe.sequenceEqual
(@NonNull MaybeSource<? extends @NonNull T> source1, @NonNull MaybeSource<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T, ? super @NonNull T> isEqual) Returns aSingle
that emits aBoolean
value that indicates whether twoMaybeSource
s are the same by comparing the items emitted by eachMaybeSource
pairwise based on the results of a specified equality function.Observable.sequenceEqual
(@NonNull ObservableSource<? extends @NonNull T> source1, @NonNull ObservableSource<? extends @NonNull T> source2, @NonNull BiPredicate<? super @NonNull T, ? super @NonNull T> isEqual) Returns aSingle
that emits aBoolean
value that indicates whether twoObservableSource
sequences are the same by comparing the items emitted by eachObservableSource
pairwise based on the results of a specified equality function.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 aSingle
that emits aBoolean
value that indicates whether twoObservableSource
sequences are the same by comparing the items emitted by eachObservableSource
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 BiPredicateModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.functions declared as BiPredicateModifier and TypeFieldDescription(package private) static final BiPredicate
<Object, Object> ObjectHelper.EQUALS
Methods in io.reactivex.rxjava3.internal.functions that return BiPredicateModifier and TypeMethodDescriptionstatic <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 BiPredicateModifier and TypeFieldDescription(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 BiPredicateModifierConstructorDescription(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 BiPredicateModifier and TypeFieldDescription(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 BiPredicateModifierConstructorDescription(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 BiPredicateModifier and TypeFieldDescription(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 BiPredicateModifierConstructorDescription(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 BiPredicateModifier and TypeFieldDescription(package private) final BiPredicate
<Object, Object> SingleContains.comparer
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type BiPredicateModifierConstructorDescriptionSingleContains
(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 BiPredicateModifier and TypeMethodDescription<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.