Class MaybeEqualSingle<T>
- java.lang.Object
-
- io.reactivex.rxjava3.core.Single<java.lang.Boolean>
-
- io.reactivex.rxjava3.internal.operators.maybe.MaybeEqualSingle<T>
-
- Type Parameters:
T
- the common base type of the sources
- All Implemented Interfaces:
SingleSource<java.lang.Boolean>
public final class MaybeEqualSingle<T> extends Single<java.lang.Boolean>
Compares two MaybeSources to see if they are both empty or emit the same value compared via a BiPredicate.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
MaybeEqualSingle.EqualCoordinator<T>
(package private) static class
MaybeEqualSingle.EqualObserver<T>
-
Field Summary
Fields Modifier and Type Field Description (package private) BiPredicate<? super T,? super T>
isEqual
(package private) MaybeSource<? extends T>
source1
(package private) MaybeSource<? extends T>
source2
-
Constructor Summary
Constructors Constructor Description MaybeEqualSingle(MaybeSource<? extends T> source1, MaybeSource<? extends T> source2, BiPredicate<? super T,? super T> isEqual)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
subscribeActual(SingleObserver<? super java.lang.Boolean> observer)
Implement this method in subclasses to handle the incomingSingleObserver
s.-
Methods inherited from class io.reactivex.rxjava3.core.Single
amb, ambArray, ambWith, blockingGet, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, cache, cast, compose, concat, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEagerDelayError, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatMap, concatMapCompletable, concatMapMaybe, concatWith, contains, contains, create, defer, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, delaySubscription, delaySubscription, delaySubscription, dematerialize, doAfterSuccess, doAfterTerminate, doFinally, doOnDispose, doOnError, doOnEvent, doOnLifecycle, doOnSubscribe, doOnSuccess, doOnTerminate, error, error, filter, flatMap, flatMap, flatMap, flatMapCompletable, flatMapMaybe, flatMapObservable, flatMapPublisher, flattenAsFlowable, flattenAsObservable, flattenStreamAsFlowable, flattenStreamAsObservable, fromCallable, fromCompletionStage, fromFuture, fromFuture, fromMaybe, fromMaybe, fromObservable, fromPublisher, fromSupplier, hide, ignoreElement, just, lift, map, mapOptional, materialize, merge, merge, merge, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, ofType, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sequenceEqual, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchOnNext, switchOnNextDelayError, takeUntil, takeUntil, takeUntil, test, test, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toCompletionStage, toFlowable, toFuture, toMaybe, toObservable, unsafeCreate, unsubscribeOn, using, using, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith
-
-
-
-
Field Detail
-
source1
final MaybeSource<? extends T> source1
-
source2
final MaybeSource<? extends T> source2
-
isEqual
final BiPredicate<? super T,? super T> isEqual
-
-
Constructor Detail
-
MaybeEqualSingle
public MaybeEqualSingle(MaybeSource<? extends T> source1, MaybeSource<? extends T> source2, BiPredicate<? super T,? super T> isEqual)
-
-
Method Detail
-
subscribeActual
protected void subscribeActual(SingleObserver<? super java.lang.Boolean> observer)
Description copied from class:Single
Implement this method in subclasses to handle the incomingSingleObserver
s.There is no need to call any of the plugin hooks on the current
Single
instance or theSingleObserver
; all hooks and basic safeguards have been applied bySingle.subscribe(SingleObserver)
before this method gets called.- Specified by:
subscribeActual
in classSingle<java.lang.Boolean>
- Parameters:
observer
- theSingleObserver
to handle, notnull
-
-