io.reactivex.internal.operators.completable

public final Class CompletableMergeDelayErrorIterable

Class Inheritance

java.lang.Object
io.reactivex.Completable
io.reactivex.internal.operators.completable.CompletableMergeDelayErrorIterable

Imports

java.util.Iterator, java.util.concurrent.atomic.AtomicInteger, io.reactivex.*, io.reactivex.disposables.CompositeDisposable, io.reactivex.exceptions.Exceptions, io.reactivex.internal.functions.ObjectHelper, io.reactivex.internal.operators.completable.CompletableMergeDelayErrorArray.MergeInnerCompletableObserver, io.reactivex.internal.util.AtomicThrowable

Field Summary

Modifier and Type	Field and Description
pack-priv final Iterable<? extends CompletableSource>	sources

Constructor Summary

Access	Constructor and Description
public	CompletableMergeDelayErrorIterable(Iterable<? extends CompletableSource> sources)

Method Summary

Modifier and Type	Method and Description
public void	subscribeActual(final CompletableObserver the CompletableObserver instance, never null observer) Implements abstract io.reactivex.Completable.subscribeActual. Implement this method to handle the incoming `CompletableObserver`s and perform the business logic in your operator.

Inherited from io.reactivex.Completable:: 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

Field Detail

sources	back to summary
pack-priv final Iterable<? extends CompletableSource> sources

Constructor Detail

CompletableMergeDelayErrorIterable	back to summary
public CompletableMergeDelayErrorIterable(Iterable<? extends CompletableSource> sources)

Method Detail

subscribeActual back to summary

subscribeActual	back to summary
public void subscribeActual(final CompletableObserver observer) Implements abstract io.reactivex.Completable.subscribeActual. Doc from io.reactivex.Completable.subscribeActual. Implement this method to handle the incoming `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 `subscribe(CompletableObserver)` before this method gets called. Parameters observer:CompletableObserver the CompletableObserver instance, never null Annotations @Override

public void subscribeActual(final CompletableObserver observer)

Implements abstract io.reactivex.Completable.subscribeActual.

Doc from io.reactivex.Completable.subscribeActual.

Implement this method to handle the incoming CompletableObservers 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 subscribe(CompletableObserver) before this method gets called.

Parameters

observer:CompletableObserver: the CompletableObserver instance, never null

Annotations

@Override