public final class CompletableConcat extends Completable
Constructor and Description |
---|
CompletableConcat(org.reactivestreams.Publisher<? extends CompletableSource> sources,
int prefetch) |
Modifier and Type | Method and Description |
---|---|
void |
subscribeActual(CompletableObserver observer)
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, delaySubscription, delaySubscription, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnSubscribe, doOnTerminate, error, error, fromAction, fromCallable, fromFuture, fromMaybe, fromObservable, fromPublisher, fromRunnable, fromSingle, hide, lift, materialize, 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, takeUntil, test, test, timeout, timeout, timeout, timeout, timer, timer, to, toFlowable, toMaybe, toObservable, toSingle, toSingleDefault, unsafeCreate, unsubscribeOn, using, using, wrap
public CompletableConcat(org.reactivestreams.Publisher<? extends CompletableSource> sources, int prefetch)
public void subscribeActual(CompletableObserver observer)
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
observer
- the CompletableObserver instance, never nullCopyright © 2019. All rights reserved.