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
andCompletable
; 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)
Signalstrue
if the currentSingle
signals a success value that is equal with the value provided by calling aBiPredicate
.@NonNull Flowable<T>
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.@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.@NonNull Completable
Completable. retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
Returns aCompletable
that retries thisCompletable
in case of an error as long as thepredicate
returnstrue
.@NonNull Flowable<T>
Flowable. retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
Returns aFlowable
that mirrors the currentFlowable
, resubscribing to it if it callsonError
and the predicate returnstrue
for that specific exception and retry count.@NonNull Maybe<T>
Maybe. retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.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.@NonNull Observable<T>
Observable. retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.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.@NonNull Single<T>
Single. retry(@NonNull BiPredicate<? super java.lang.Integer,? super java.lang.Throwable> predicate)
Re-subscribe to the currentSingle
if the given predicate returnstrue
when theSingle
fails with anonError
.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 aSingle
that emits aBoolean
value that indicates whether twoPublisher
sequences are the same by comparing the items emitted by eachPublisher
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 aSingle
that emits aBoolean
value that indicates whether twoPublisher
sequences are the same by comparing the items emitted by eachPublisher
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 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.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 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.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 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 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.
-