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 TypeMethodDescriptionSignalstrueif the currentSinglesignals 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 aFlowablethat emits all items emitted by the currentFlowablethat 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 anObservablethat emits all items emitted by the currentObservablethat are distinct from their immediate predecessors when compared with each other via the provided comparator function.final @NonNull CompletableCompletable.retry(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Returns aCompletablethat retries thisCompletablein case of an error as long as thepredicatereturnstrue.Returns aFlowablethat mirrors the currentFlowable, resubscribing to it if it callsonErrorand the predicate returnstruefor that specific exception and retry count.Maybe.retry(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Returns aMaybethat mirrors the currentMaybe, resubscribing to it if it callsonErrorand the predicate returnstruefor that specific exception and retry count.final @NonNull Observable<T> Observable.retry(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Returns anObservablethat mirrors the currentObservable, resubscribing to it if it callsonErrorand the predicate returnstruefor that specific exception and retry count.Single.retry(@NonNull BiPredicate<? super Integer, ? super Throwable> predicate) Re-subscribe to the currentSingleif the given predicate returnstruewhen theSinglefails 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 aSinglethat emits aBooleanvalue that indicates whether twoMaybeSources are the same by comparing the items emitted by eachMaybeSourcepairwise 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 aSinglethat emits aBooleanvalue that indicates whether twoObservableSourcesequences are the same by comparing the items emitted by eachObservableSourcepairwise 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 aSinglethat emits aBooleanvalue that indicates whether twoObservableSourcesequences are the same by comparing the items emitted by eachObservableSourcepairwise 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 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
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BiPredicateModifierConstructorDescriptionFlowableDistinctUntilChanged(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 BiPredicateModifierConstructorDescriptionMaybeEqualSingle(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 BiPredicateModifierConstructorDescriptionObservableDistinctUntilChanged(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 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> voidAppendOnlyLinkedArrayList.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.