Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.functions | |
io.reactivex.internal.operators.flowable | |
io.reactivex.internal.operators.maybe | |
io.reactivex.internal.operators.observable | |
io.reactivex.internal.operators.single | |
io.reactivex.internal.util |
Modifier and Type | Method and Description |
---|---|
Single<Boolean> |
Single.contains(Object value,
BiPredicate<Object,Object> comparer)
Signals true if the current Single signals a success value that is equal with
the value provided by calling a bi-predicate.
|
Observable<T> |
Observable.distinctUntilChanged(BiPredicate<? super T,? super T> comparer)
Returns an Observable that emits all items emitted by the source ObservableSource that are distinct from their
immediate predecessors when compared with each other via the provided comparator function.
|
Flowable<T> |
Flowable.distinctUntilChanged(BiPredicate<? super T,? super T> comparer)
Returns a Flowable that emits all items emitted by the source Publisher that are distinct from their
immediate predecessors when compared with each other via the provided comparator function.
|
Single<T> |
Single.retry(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.
|
Observable<T> |
Observable.retry(BiPredicate<? super Integer,? super Throwable> predicate)
Returns an Observable that mirrors the source ObservableSource, resubscribing to it if it calls
onError
and the predicate returns true for that specific exception and retry count. |
Maybe<T> |
Maybe.retry(BiPredicate<? super Integer,? super Throwable> predicate)
Returns a Maybe that mirrors the source Maybe, resubscribing to it if it calls
onError
and the predicate returns true for that specific exception and retry count. |
Flowable<T> |
Flowable.retry(BiPredicate<? super Integer,? super Throwable> predicate)
Returns a Flowable that mirrors the source Publisher, resubscribing to it if it calls
onError
and the predicate returns true for that specific exception and retry count. |
Completable |
Completable.retry(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.
|
static <T> Single<Boolean> |
Maybe.sequenceEqual(MaybeSource<? extends T> source1,
MaybeSource<? extends T> source2,
BiPredicate<? super T,? super 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 <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
BiPredicate<? super T,? super 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 <T> Single<Boolean> |
Observable.sequenceEqual(ObservableSource<? extends T> source1,
ObservableSource<? extends T> source2,
BiPredicate<? super T,? super 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.
|
static <T> Single<Boolean> |
Flowable.sequenceEqual(org.reactivestreams.Publisher<? extends T> source1,
org.reactivestreams.Publisher<? extends T> source2,
BiPredicate<? super T,? super 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 <T> Single<Boolean> |
Flowable.sequenceEqual(org.reactivestreams.Publisher<? extends T> source1,
org.reactivestreams.Publisher<? extends T> source2,
BiPredicate<? super T,? super 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.
|
Modifier and Type | Method and Description |
---|---|
static <T> BiPredicate<T,T> |
ObjectHelper.equalsPredicate()
Returns a BiPredicate that compares its parameters via Objects.equals().
|
Constructor and 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) |
Constructor and Description |
---|
MaybeEqualSingle(MaybeSource<? extends T> source1,
MaybeSource<? extends T> source2,
BiPredicate<? super T,? super T> isEqual) |
Constructor and 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) |
Constructor and Description |
---|
SingleContains(SingleSource<T> source,
Object value,
BiPredicate<Object,Object> comparer) |
Modifier and Type | Method and 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.
|
Copyright © 2019. All rights reserved.