T
- the value typepublic final class ObservableLastMaybe<T> extends Maybe<T>
Constructor and Description |
---|
ObservableLastMaybe(ObservableSource<T> source) |
Modifier and Type | Method and Description |
---|---|
protected void |
subscribeActual(MaybeObserver<? super T> observer)
Implement this method in subclasses to handle the incoming
MaybeObserver s. |
amb, ambArray, ambWith, as, blockingGet, blockingGet, cache, cast, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatDelayError, concatDelayError, concatEager, concatEager, concatMap, concatWith, contains, count, create, defaultIfEmpty, defer, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, doAfterSuccess, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnSubscribe, doOnSuccess, empty, error, error, filter, flatMap, flatMap, flatMap, flatMapCompletable, flatMapObservable, flatMapPublisher, flatMapSingle, flatMapSingleElement, flattenAsFlowable, flattenAsObservable, fromAction, fromCallable, fromCompletable, fromFuture, fromFuture, fromRunnable, fromSingle, hide, ignoreElement, isEmpty, just, lift, map, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, ofType, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturnItem, onExceptionResumeNext, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryUntil, retryWhen, sequenceEqual, sequenceEqual, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, switchIfEmpty, switchIfEmpty, takeUntil, takeUntil, test, test, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, to, toFlowable, toObservable, toSingle, toSingle, unsafeCreate, unsubscribeOn, using, using, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith
public ObservableLastMaybe(ObservableSource<T> source)
protected void subscribeActual(MaybeObserver<? super T> observer)
Maybe
MaybeObserver
s.
There is no need to call any of the plugin hooks on the current Maybe
instance or
the MaybeObserver
; all hooks and basic safeguards have been
applied by Maybe.subscribe(MaybeObserver)
before this method gets called.
subscribeActual
in class Maybe<T>
observer
- the MaybeObserver to handle, not nullCopyright © 2018 JBoss by Red Hat. All rights reserved.