Uses of Interface
io.reactivex.rxjava3.functions.Predicate
-
Packages that use Predicate 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.observers io.reactivex.rxjava3.internal.operators.completable io.reactivex.rxjava3.internal.operators.flowable io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.operators.observable io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.internal.operators.single io.reactivex.rxjava3.internal.subscribers io.reactivex.rxjava3.internal.util io.reactivex.rxjava3.observers Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and theTestObserver
that allows unit testingObservable
-,Single
-,Maybe
- andCompletable
-based flows.io.reactivex.rxjava3.parallel Contains the base typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel.io.reactivex.rxjava3.processors Classes representing so-called hot backpressure-aware sources, aka processors, that implement theFlowableProcessor
class, the Reactive StreamsProcessor
interface to allow forms of multicasting events to one or more subscribers as well as consuming another Reactive StreamsPublisher
.io.reactivex.rxjava3.subjects Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind. -
-
Uses of Predicate in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type Predicate Modifier and Type Method Description @NonNull Single<java.lang.Boolean>
Flowable. all(@NonNull Predicate<? super @NonNull T> predicate)
Returns aSingle
that emits aBoolean
that indicates whether all of the items emitted by the currentFlowable
satisfy a condition.@NonNull Single<java.lang.Boolean>
Observable. all(@NonNull Predicate<? super @NonNull T> predicate)
Returns aSingle
that emits aBoolean
that indicates whether all of the items emitted by the currentObservable
satisfy a condition.@NonNull Single<java.lang.Boolean>
Flowable. any(@NonNull Predicate<? super @NonNull T> predicate)
Returns aSingle
that emitstrue
if any item emitted by the currentFlowable
satisfies a specified condition, otherwisefalse
.@NonNull Single<java.lang.Boolean>
Observable. any(@NonNull Predicate<? super @NonNull T> predicate)
Returns aSingle
that emitstrue
if any item emitted by the currentObservable
satisfies a specified condition, otherwisefalse
.@NonNull Flowable<T>
Flowable. filter(@NonNull Predicate<? super @NonNull T> predicate)
Filters items emitted by the currentFlowable
by only emitting those that satisfy a specified predicate.@NonNull Maybe<T>
Maybe. filter(@NonNull Predicate<? super @NonNull T> predicate)
Filters the success item of theMaybe
via a predicate function and emitting it if the predicate returnstrue
, completing otherwise.@NonNull Observable<T>
Observable. filter(@NonNull Predicate<? super @NonNull T> predicate)
Filters items emitted by the currentObservable
by only emitting those that satisfy a specifiedPredicate
.@NonNull Maybe<T>
Single. filter(@NonNull Predicate<? super @NonNull T> predicate)
Filters the success item of theSingle
via a predicate function and emitting it if the predicate returnstrue
, completing otherwise.@NonNull Disposable
Flowable. forEachWhile(@NonNull Predicate<? super @NonNull T> onNext)
Subscribes to the currentFlowable
and receives notifications for each element until theonNext
Predicate returnsfalse
.@NonNull Disposable
Flowable. forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super java.lang.Throwable> onError)
Subscribes to the currentFlowable
and receives notifications for each element and error events until theonNext
Predicate returnsfalse
.@NonNull Disposable
Flowable. forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super java.lang.Throwable> onError, @NonNull Action onComplete)
Subscribes to the currentFlowable
and receives notifications for each element and the terminal events until theonNext
Predicate returnsfalse
.@NonNull Disposable
Observable. forEachWhile(@NonNull Predicate<? super @NonNull T> onNext)
Subscribes to theObservableSource
and calls aPredicate
for each item of the currentObservable
, on its emission thread, until the predicate returnsfalse
.@NonNull Disposable
Observable. forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super java.lang.Throwable> onError)
Subscribes to theObservableSource
and calls aPredicate
for each item or aConsumer
with the error of the currentObservable
, on their original emission threads, until the predicate returnsfalse
.@NonNull Disposable
Observable. forEachWhile(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super java.lang.Throwable> onError, @NonNull Action onComplete)
Subscribes to theObservableSource
and calls aPredicate
for each item, aConsumer
with the error or anAction
upon completion of the currentObservable
, on their original emission threads, until the predicate returnsfalse
.@NonNull Completable
Completable. onErrorComplete(@NonNull Predicate<? super java.lang.Throwable> predicate)
Returns aCompletable
instance that if thisCompletable
emits an error and thePredicate
returnstrue
, it will emit anonComplete
and swallow theThrowable
.@NonNull Flowable<T>
Flowable. onErrorComplete(@NonNull Predicate<? super java.lang.Throwable> predicate)
Returns aFlowable
instance that if the currentFlowable
emits an error and the predicate returnstrue
, it will emit anonComplete
and swallow the throwable.@NonNull Maybe<T>
Maybe. onErrorComplete(@NonNull Predicate<? super java.lang.Throwable> predicate)
Returns aMaybe
instance that if thisMaybe
emits an error and the predicate returnstrue
, it will emit anonComplete
and swallow the throwable.@NonNull Observable<T>
Observable. onErrorComplete(@NonNull Predicate<? super java.lang.Throwable> predicate)
Returns anObservable
instance that if the currentObservable
emits an error and the predicate returnstrue
, it will emit anonComplete
and swallow the throwable.@NonNull Maybe<T>
Single. onErrorComplete(@NonNull Predicate<? super java.lang.Throwable> predicate)
Returns aMaybe
instance that if thisSingle
emits an error and the predicate returnstrue
, it will emit anonComplete
and swallow the throwable.@NonNull Completable
Completable. retry(long times, @NonNull Predicate<? super java.lang.Throwable> predicate)
Returns aCompletable
that when thisCompletable
emits an error, retries at most times or until the predicate returnsfalse
, whichever happens first and emitting the last error.@NonNull Completable
Completable. retry(@NonNull Predicate<? super java.lang.Throwable> predicate)
Returns aCompletable
that when thisCompletable
emits an error, calls the given predicate with the latestThrowable
to decide whether to resubscribe to the upstream or not.@NonNull Flowable<T>
Flowable. retry(long times, @NonNull Predicate<? super java.lang.Throwable> predicate)
Retries at most times or until the predicate returnsfalse
, whichever happens first.@NonNull Flowable<T>
Flowable. retry(@NonNull Predicate<? super java.lang.Throwable> predicate)
Retries the currentFlowable
if the predicate returnstrue
.@NonNull Maybe<T>
Maybe. retry(long times, @NonNull Predicate<? super java.lang.Throwable> predicate)
Retries at mosttimes
or until the predicate returnsfalse
, whichever happens first.@NonNull Maybe<T>
Maybe. retry(@NonNull Predicate<? super java.lang.Throwable> predicate)
Retries the currentMaybe
if it fails and the predicate returnstrue
.@NonNull Observable<T>
Observable. retry(long times, @NonNull Predicate<? super java.lang.Throwable> predicate)
Retries at most times or until the predicate returnsfalse
, whichever happens first.@NonNull Observable<T>
Observable. retry(@NonNull Predicate<? super java.lang.Throwable> predicate)
Retries the currentObservable
if the predicate returnstrue
.@NonNull Single<T>
Single. retry(long times, @NonNull Predicate<? super java.lang.Throwable> predicate)
Repeatedly re-subscribe at most times or until the predicate returnsfalse
, whichever happens first if it fails with anonError
.@NonNull Single<T>
Single. retry(@NonNull Predicate<? super java.lang.Throwable> predicate)
Re-subscribe to the currentSingle
if the given predicate returnstrue
when theSingle
fails with anonError
.@NonNull Flowable<T>
Flowable. skipWhile(@NonNull Predicate<? super @NonNull T> predicate)
Returns aFlowable
that skips all items emitted by the currentFlowable
as long as a specified condition holdstrue
, but emits all further source items as soon as the condition becomesfalse
.@NonNull Observable<T>
Observable. skipWhile(@NonNull Predicate<? super @NonNull T> predicate)
Returns anObservable
that skips all items emitted by the currentObservable
as long as a specified condition holdstrue
, but emits all further source items as soon as the condition becomesfalse
.@NonNull Flowable<T>
Flowable. takeUntil(@NonNull Predicate<? super @NonNull T> stopPredicate)
Returns aFlowable
that emits items emitted by the currentFlowable
, checks the specified predicate for each item, and then completes when the condition is satisfied.@NonNull Observable<T>
Observable. takeUntil(@NonNull Predicate<? super @NonNull T> stopPredicate)
Returns anObservable
that emits items emitted by the currentObservable
, checks the specified predicate for each item, and then completes when the condition is satisfied.@NonNull Flowable<T>
Flowable. takeWhile(@NonNull Predicate<? super @NonNull T> predicate)
Returns aFlowable
that emits items emitted by the currentFlowable
so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied.@NonNull Observable<T>
Observable. takeWhile(@NonNull Predicate<? super @NonNull T> predicate)
Returns anObservable
that emits items emitted by the currentObservable
so long as each item satisfied a specified condition, and then completes as soon as this condition is not satisfied. -
Uses of Predicate in io.reactivex.rxjava3.internal.functions
Classes in io.reactivex.rxjava3.internal.functions that implement Predicate Modifier and Type Class Description (package private) static class
Functions.BooleanSupplierPredicateReverse<T>
(package private) static class
Functions.ClassFilter<T,U>
(package private) static class
Functions.EqualsPredicate<T>
(package private) static class
Functions.FalsePredicate
(package private) static class
Functions.TruePredicate
Fields in io.reactivex.rxjava3.internal.functions declared as Predicate Modifier and Type Field Description (package private) static Predicate<java.lang.Object>
Functions. ALWAYS_FALSE
(package private) static Predicate<java.lang.Object>
Functions. ALWAYS_TRUE
Methods in io.reactivex.rxjava3.internal.functions that return Predicate Modifier and Type Method Description static <T> @NonNull Predicate<T>
Functions. alwaysFalse()
static <T> @NonNull Predicate<T>
Functions. alwaysTrue()
static <T> Predicate<T>
Functions. equalsWith(T value)
static <T,U>
Predicate<T>Functions. isInstanceOf(java.lang.Class<U> clazz)
static <T> Predicate<T>
Functions. predicateReverseFor(BooleanSupplier supplier)
-
Uses of Predicate in io.reactivex.rxjava3.internal.observers
Fields in io.reactivex.rxjava3.internal.observers declared as Predicate Modifier and Type Field Description (package private) Predicate<? super T>
ForEachWhileObserver. onNext
Constructors in io.reactivex.rxjava3.internal.observers with parameters of type Predicate Constructor Description ForEachWhileObserver(Predicate<? super T> onNext, Consumer<? super java.lang.Throwable> onError, Action onComplete)
-
Uses of Predicate in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as Predicate Modifier and Type Field Description private Predicate<? super java.lang.Throwable>
CompletableOnErrorComplete.OnError. predicate
(package private) Predicate<? super java.lang.Throwable>
CompletableOnErrorComplete. predicate
Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type Predicate Constructor Description CompletableOnErrorComplete(CompletableSource source, Predicate<? super java.lang.Throwable> predicate)
OnError(CompletableObserver observer, Predicate<? super java.lang.Throwable> predicate)
-
Uses of Predicate in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as Predicate Modifier and Type Field Description (package private) Predicate<? super T>
FlowableFilter.FilterConditionalSubscriber. filter
(package private) Predicate<? super T>
FlowableFilter.FilterSubscriber. filter
(package private) Predicate<? super T>
FlowableAll.AllSubscriber. predicate
(package private) Predicate<? super T>
FlowableAll. predicate
(package private) Predicate<? super T>
FlowableAllSingle.AllSubscriber. predicate
(package private) Predicate<? super T>
FlowableAllSingle. predicate
(package private) Predicate<? super T>
FlowableAny.AnySubscriber. predicate
(package private) Predicate<? super T>
FlowableAny. predicate
(package private) Predicate<? super T>
FlowableAnySingle.AnySubscriber. predicate
(package private) Predicate<? super T>
FlowableAnySingle. predicate
(package private) Predicate<? super T>
FlowableFilter. predicate
(package private) Predicate<? super java.lang.Throwable>
FlowableOnErrorComplete.OnErrorCompleteSubscriber. predicate
(package private) Predicate<? super java.lang.Throwable>
FlowableOnErrorComplete. predicate
(package private) Predicate<? super java.lang.Throwable>
FlowableRetryPredicate. predicate
(package private) Predicate<? super java.lang.Throwable>
FlowableRetryPredicate.RetrySubscriber. predicate
(package private) Predicate<? super T>
FlowableSkipWhile. predicate
(package private) Predicate<? super T>
FlowableSkipWhile.SkipWhileSubscriber. predicate
(package private) Predicate<? super T>
FlowableTakeUntilPredicate.InnerSubscriber. predicate
(package private) Predicate<? super T>
FlowableTakeUntilPredicate. predicate
(package private) Predicate<? super T>
FlowableTakeWhile. predicate
(package private) Predicate<? super T>
FlowableTakeWhile.TakeWhileSubscriber. predicate
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type Predicate Constructor Description AllSubscriber(org.reactivestreams.Subscriber<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
AllSubscriber(SingleObserver<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
AnySubscriber(org.reactivestreams.Subscriber<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
AnySubscriber(SingleObserver<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
FilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> filter)
FilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> filter)
FlowableAll(Flowable<T> source, Predicate<? super T> predicate)
FlowableAllSingle(Flowable<T> source, Predicate<? super T> predicate)
FlowableAny(Flowable<T> source, Predicate<? super T> predicate)
FlowableAnySingle(Flowable<T> source, Predicate<? super T> predicate)
FlowableFilter(Flowable<T> source, Predicate<? super T> predicate)
FlowableOnErrorComplete(Flowable<T> source, Predicate<? super java.lang.Throwable> predicate)
FlowableRetryPredicate(Flowable<T> source, long count, Predicate<? super java.lang.Throwable> predicate)
FlowableSkipWhile(Flowable<T> source, Predicate<? super T> predicate)
FlowableTakeUntilPredicate(Flowable<T> source, Predicate<? super T> predicate)
FlowableTakeWhile(Flowable<T> source, Predicate<? super T> predicate)
InnerSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
OnErrorCompleteSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super java.lang.Throwable> predicate)
RetrySubscriber(org.reactivestreams.Subscriber<? super T> actual, long count, Predicate<? super java.lang.Throwable> predicate, SubscriptionArbiter sa, org.reactivestreams.Publisher<? extends T> source)
SkipWhileSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
TakeWhileSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
-
Uses of Predicate in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as Predicate Modifier and Type Field Description (package private) Predicate<? super T>
MaybeFilter.FilterMaybeObserver. predicate
(package private) Predicate<? super T>
MaybeFilter. predicate
(package private) Predicate<? super T>
MaybeFilterSingle.FilterMaybeObserver. predicate
(package private) Predicate<? super T>
MaybeFilterSingle. predicate
(package private) Predicate<? super java.lang.Throwable>
MaybeOnErrorComplete.OnErrorCompleteMultiObserver. predicate
(package private) Predicate<? super java.lang.Throwable>
MaybeOnErrorComplete. predicate
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type Predicate Constructor Description FilterMaybeObserver(MaybeObserver<? super T> actual, Predicate<? super T> predicate)
FilterMaybeObserver(MaybeObserver<? super T> actual, Predicate<? super T> predicate)
MaybeFilter(MaybeSource<T> source, Predicate<? super T> predicate)
MaybeFilterSingle(SingleSource<T> source, Predicate<? super T> predicate)
MaybeOnErrorComplete(MaybeSource<T> source, Predicate<? super java.lang.Throwable> predicate)
OnErrorCompleteMultiObserver(MaybeObserver<? super T> actual, Predicate<? super java.lang.Throwable> predicate)
-
Uses of Predicate in io.reactivex.rxjava3.internal.operators.observable
Fields in io.reactivex.rxjava3.internal.operators.observable declared as Predicate Modifier and Type Field Description (package private) Predicate<? super T>
ObservableFilter.FilterObserver. filter
(package private) Predicate<? super T>
ObservableAll.AllObserver. predicate
(package private) Predicate<? super T>
ObservableAll. predicate
(package private) Predicate<? super T>
ObservableAllSingle.AllObserver. predicate
(package private) Predicate<? super T>
ObservableAllSingle. predicate
(package private) Predicate<? super T>
ObservableAny.AnyObserver. predicate
(package private) Predicate<? super T>
ObservableAny. predicate
(package private) Predicate<? super T>
ObservableAnySingle.AnyObserver. predicate
(package private) Predicate<? super T>
ObservableAnySingle. predicate
(package private) Predicate<? super T>
ObservableFilter. predicate
(package private) Predicate<? super java.lang.Throwable>
ObservableOnErrorComplete.OnErrorCompleteObserver. predicate
(package private) Predicate<? super java.lang.Throwable>
ObservableOnErrorComplete. predicate
(package private) Predicate<? super java.lang.Throwable>
ObservableRetryPredicate. predicate
(package private) Predicate<? super java.lang.Throwable>
ObservableRetryPredicate.RepeatObserver. predicate
(package private) Predicate<? super T>
ObservableSkipWhile. predicate
(package private) Predicate<? super T>
ObservableSkipWhile.SkipWhileObserver. predicate
(package private) Predicate<? super T>
ObservableTakeUntilPredicate. predicate
(package private) Predicate<? super T>
ObservableTakeUntilPredicate.TakeUntilPredicateObserver. predicate
(package private) Predicate<? super T>
ObservableTakeWhile. predicate
(package private) Predicate<? super T>
ObservableTakeWhile.TakeWhileObserver. predicate
Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Predicate Constructor Description AllObserver(Observer<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
AllObserver(SingleObserver<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
AnyObserver(Observer<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
AnyObserver(SingleObserver<? super java.lang.Boolean> actual, Predicate<? super T> predicate)
FilterObserver(Observer<? super T> actual, Predicate<? super T> filter)
ObservableAll(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableAllSingle(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableAny(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableAnySingle(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableFilter(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableOnErrorComplete(ObservableSource<T> source, Predicate<? super java.lang.Throwable> predicate)
ObservableRetryPredicate(Observable<T> source, long count, Predicate<? super java.lang.Throwable> predicate)
ObservableSkipWhile(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableTakeUntilPredicate(ObservableSource<T> source, Predicate<? super T> predicate)
ObservableTakeWhile(ObservableSource<T> source, Predicate<? super T> predicate)
OnErrorCompleteObserver(Observer<? super T> actual, Predicate<? super java.lang.Throwable> predicate)
RepeatObserver(Observer<? super T> actual, long count, Predicate<? super java.lang.Throwable> predicate, SequentialDisposable sa, ObservableSource<? extends T> source)
SkipWhileObserver(Observer<? super T> actual, Predicate<? super T> predicate)
TakeUntilPredicateObserver(Observer<? super T> downstream, Predicate<? super T> predicate)
TakeWhileObserver(Observer<? super T> actual, Predicate<? super T> predicate)
-
Uses of Predicate in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as Predicate Modifier and Type Field Description (package private) Predicate<? super T>
ParallelFilter.BaseFilterSubscriber. predicate
(package private) Predicate<? super T>
ParallelFilter. predicate
(package private) Predicate<? super T>
ParallelFilterTry.BaseFilterSubscriber. predicate
(package private) Predicate<? super T>
ParallelFilterTry. predicate
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type Predicate Constructor Description BaseFilterSubscriber(Predicate<? super T> predicate)
BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilter(ParallelFlowable<T> source, Predicate<? super T> predicate)
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate)
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate)
ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterTry(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
-
Uses of Predicate in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single declared as Predicate Modifier and Type Field Description (package private) Predicate<? super java.lang.Throwable>
SingleOnErrorComplete. predicate
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type Predicate Constructor Description SingleOnErrorComplete(Single<T> source, Predicate<? super java.lang.Throwable> predicate)
-
Uses of Predicate in io.reactivex.rxjava3.internal.subscribers
Fields in io.reactivex.rxjava3.internal.subscribers declared as Predicate Modifier and Type Field Description (package private) Predicate<? super T>
ForEachWhileSubscriber. onNext
Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type Predicate Constructor Description ForEachWhileSubscriber(Predicate<? super T> onNext, Consumer<? super java.lang.Throwable> onError, Action onComplete)
-
Uses of Predicate in io.reactivex.rxjava3.internal.util
Subinterfaces of Predicate in io.reactivex.rxjava3.internal.util Modifier and Type Interface Description static interface
AppendOnlyLinkedArrayList.NonThrowingPredicate<T>
Predicate interface suppressing the exception. -
Uses of Predicate in io.reactivex.rxjava3.observers
Methods in io.reactivex.rxjava3.observers with parameters of type Predicate Modifier and Type Method Description U
BaseTestConsumer. assertError(@NonNull Predicate<java.lang.Throwable> errorPredicate)
Asserts that thisTestObserver
/TestSubscriber
received exactly oneonError
event for which the provided predicate returnstrue
.private U
BaseTestConsumer. assertError(@NonNull Predicate<java.lang.Throwable> errorPredicate, boolean exact)
U
BaseTestConsumer. assertValue(@NonNull Predicate<T> valuePredicate)
Asserts that thisTestObserver
/TestSubscriber
received exactly oneonNext
value for which the provided predicate returnstrue
.U
BaseTestConsumer. assertValueAt(int index, @NonNull Predicate<T> valuePredicate)
Asserts that thisTestObserver
/TestSubscriber
received anonNext
value at the given index for the provided predicate returnstrue
. -
Uses of Predicate in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel with parameters of type Predicate Modifier and Type Method Description @NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate)
Filters the source values on each 'rail'.@NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.@NonNull ParallelFlowable<T>
ParallelFlowable. filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull ParallelFailureHandling errorHandler)
Filters the source values on each 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value. -
Uses of Predicate in io.reactivex.rxjava3.processors
Classes in io.reactivex.rxjava3.processors that implement Predicate Modifier and Type Class Description (package private) static class
BehaviorProcessor.BehaviorSubscription<T>
-
Uses of Predicate in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement Predicate Modifier and Type Class Description (package private) static class
BehaviorSubject.BehaviorDisposable<T>
(package private) class
SerializedSubject<T>
Serializes calls to the Observer methods.
-