Top Inners Fields Constructors Methods
io.reactivex.internal.operators.completable

public final Class CompletableMergeDelayErrorArray

extends Completable
Class Inheritance
Imports
java.util.concurrent.atomic.AtomicInteger, io.reactivex.*, io.reactivex.disposables.*, io.reactivex.internal.util.AtomicThrowable, io.reactivex.plugins.RxJavaPlugins

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
CompletableMergeDelayErrorArray.MergeInnerCompletableObserver

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableSource[]
sources

Constructor Summary

AccessConstructor and Description
public
CompletableMergeDelayErrorArray(CompletableSource[] sources)

Method Summary

Modifier and TypeMethod 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 CompletableObservers and perform the business logic in your operator.
Inherited from io.reactivex.Completable:
ambambArrayambWithandThenandThenandThenandThenandThenasblockingAwaitblockingAwaitblockingGetblockingGetcachecompletecomposeconcatconcatconcatconcatArrayconcatWithcreatedeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnSubscribedoOnTerminateerrorerrorfromActionfromCallablefromFuturefromMaybefromObservablefromPublisherfromRunnablefromSinglehideliftmaterializemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnonErrorCompleteonErrorCompleteonErrorResumeNextonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryWhenstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribeOnsubscribeWithtakeUntiltesttesttimeouttimeouttimeouttimeouttimertimertotoFlowabletoMaybetoObservabletoSingletoSingleDefaultunsafeCreateunsubscribeOnusingusingwrap

Field Detail

sourcesback to summary
pack-priv final CompletableSource[] sources

Constructor Detail

CompletableMergeDelayErrorArrayback to summary
public CompletableMergeDelayErrorArray(CompletableSource[] sources)

Method Detail

subscribeActualback 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 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
io.reactivex.internal.operators.completable back to summary

pack-priv final Class CompletableMergeDelayErrorArray.MergeInnerCompletableObserver

extends Object
implements CompletableObserver
Class Inheritance
  • java.lang.Object
  • io.reactivex.internal.operators.completable.CompletableMergeDelayErrorArray.MergeInnerCompletableObserver
All Implemented Interfaces
io.reactivex.CompletableObserver

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableObserver
downstream

pack-priv final AtomicThrowable
error

pack-priv final CompositeDisposable
set

pack-priv final AtomicInteger
wip

Constructor Summary

AccessConstructor and Description
pack-priv
MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, AtomicInteger wip)

Method Summary

Modifier and TypeMethod and Description
public void
onComplete()

Implements io.reactivex.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(Throwable
the exception, not null.
e)

Implements io.reactivex.CompletableObserver.onError.

Called once if the deferred computation 'throws' an exception.
public void
onSubscribe(Disposable
the Disposable instance to call dispose on for cancellation, not null
d)

Implements io.reactivex.CompletableObserver.onSubscribe.

Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.
pack-priv void
tryTerminate()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

downstreamback to summary
pack-priv final CompletableObserver downstream
errorback to summary
pack-priv final AtomicThrowable error
setback to summary
pack-priv final CompositeDisposable set
wipback to summary
pack-priv final AtomicInteger wip

Constructor Detail

MergeInnerCompletableObserverback to summary
pack-priv MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, AtomicInteger wip)

Method Detail

onCompleteback to summary
public void onComplete()

Implements io.reactivex.CompletableObserver.onComplete.

Doc from io.reactivex.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)

Implements io.reactivex.CompletableObserver.onError.

Doc from io.reactivex.CompletableObserver.onError.

Called once if the deferred computation 'throws' an exception.

Parameters
e:Throwable

the exception, not null.

Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)

Implements io.reactivex.CompletableObserver.onSubscribe.

Doc from io.reactivex.CompletableObserver.onSubscribe.

Called once by the Completable to set a Disposable on this instance which then can be used to cancel the subscription at any time.

Parameters
d:Disposable

the Disposable instance to call dispose on for cancellation, not null

Annotations
@Override
tryTerminateback to summary
pack-priv void tryTerminate()