public final class ObservableIgnoreElementsCompletable<T> extends Completable implements FuseToObservable<T>
Constructor and Description |
---|
ObservableIgnoreElementsCompletable(ObservableSource<T> source) |
Modifier and Type | Method and Description |
---|---|
Observable<T> |
fuseToObservable()
Returns a (direct) Observable for the operator.
|
void |
subscribeActual(CompletableObserver t)
Implement this method to handle the incoming
CompletableObserver s and
perform the business logic in your operator. |
amb, ambArray, ambWith, andThen, andThen, andThen, andThen, andThen, as, blockingAwait, blockingAwait, blockingGet, blockingGet, cache, complete, compose, concat, concat, concat, concatArray, concatWith, create, defer, delay, delay, delay, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnSubscribe, doOnTerminate, error, error, fromAction, fromCallable, fromFuture, fromObservable, fromPublisher, fromRunnable, fromSingle, hide, lift, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, onErrorComplete, onErrorComplete, onErrorResumeNext, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryWhen, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, test, test, timeout, timeout, timeout, timeout, timer, timer, to, toFlowable, toMaybe, toObservable, toSingle, toSingleDefault, unsafeCreate, unsubscribeOn, using, using, wrap
public ObservableIgnoreElementsCompletable(ObservableSource<T> source)
public void subscribeActual(CompletableObserver t)
Completable
CompletableObserver
s and
perform the business logic in your operator.
There is no need to call any of the plugin hooks on the current Completable
instance or
the CompletableObserver
; all hooks and basic safeguards have been
applied by Completable.subscribe(CompletableObserver)
before this method gets called.
subscribeActual
in class Completable
t
- the CompletableObserver instance, never nullpublic Observable<T> fuseToObservable()
FuseToObservable
The implementation should handle the necessary RxJavaPlugins wrapping.
fuseToObservable
in interface FuseToObservable<T>
Copyright © 2018 JBoss by Red Hat. All rights reserved.