public final class ObservableAnySingle<T> extends Single<Boolean> implements FuseToObservable<Boolean>
Constructor and Description |
---|
ObservableAnySingle(ObservableSource<T> source,
Predicate<? super T> predicate) |
Modifier and Type | Method and Description |
---|---|
Observable<Boolean> |
fuseToObservable()
Returns a (direct) Observable for the operator.
|
protected void |
subscribeActual(SingleObserver<? super Boolean> t)
Implement this method in subclasses to handle the incoming
SingleObserver s. |
amb, ambArray, ambWith, as, blockingGet, cache, cast, compose, concat, concat, concat, concat, concat, concat, concat, concatArray, concatArrayEager, concatEager, concatEager, concatWith, contains, contains, create, defer, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, delaySubscription, delaySubscription, delaySubscription, doAfterSuccess, doAfterTerminate, doFinally, doOnDispose, doOnError, doOnEvent, doOnSubscribe, doOnSuccess, equals, error, error, filter, flatMap, flatMapCompletable, flatMapMaybe, flatMapObservable, flatMapPublisher, flattenAsFlowable, flattenAsObservable, fromCallable, fromFuture, fromFuture, fromFuture, fromFuture, fromObservable, fromPublisher, hide, ignoreElement, just, lift, map, merge, merge, merge, merge, merge, merge, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturnItem, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryWhen, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, takeUntil, takeUntil, takeUntil, test, test, timeout, timeout, timeout, timeout, timer, timer, to, toCompletable, toFlowable, toFuture, toMaybe, toObservable, unsafeCreate, unsubscribeOn, using, using, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith
public ObservableAnySingle(ObservableSource<T> source, Predicate<? super T> predicate)
protected void subscribeActual(SingleObserver<? super Boolean> t)
Single
SingleObserver
s.
There is no need to call any of the plugin hooks on the current Single
instance or
the SingleObserver
; all hooks and basic safeguards have been
applied by Single.subscribe(SingleObserver)
before this method gets called.
subscribeActual
in class Single<Boolean>
t
- the SingleObserver to handle, not nullpublic Observable<Boolean> fuseToObservable()
FuseToObservable
The implementation should handle the necessary RxJavaPlugins wrapping.
fuseToObservable
in interface FuseToObservable<Boolean>
Copyright © 2018 JBoss by Red Hat. All rights reserved.