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

public final Class CompletableMergeDelayErrorIterable

extends Completable
Class Inheritance
Imports
java.util.Iterator, .Objects, java.util.concurrent.atomic.AtomicInteger, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.CompositeDisposable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.internal.operators.completable.CompletableMergeArrayDelayError.*, io.reactivex.rxjava3.internal.util.AtomicThrowable

Field Summary

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

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
public void
subscribeActual(final CompletableObserver observer)

Inherited from io.reactivex.rxjava3.core.Completable:
ambambArrayambWithandThenandThenandThenandThenandThenblockingAwaitblockingAwaitblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecompletecomposeconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatWithcreatedeferdelaydelaydelaydelaySubscriptiondelaySubscriptiondoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnTerminateerrorerrorfromActionfromCallablefromCompletionStagefromFuturefromMaybefromObservablefromPublisherfromRunnablefromSinglefromSupplierhideliftmaterializemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchOnNextswitchOnNextDelayErrortakeUntiltesttesttimeouttimeouttimeouttimeouttimertimertotoCompletionStagetoFlowabletoFuturetoMaybetoObservabletoSingletoSingleDefaultunsafeCreateunsubscribeOnusingusingwrap

Field Detail

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

Constructor Detail

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

Method Detail

subscribeActualback to summary
public void subscribeActual(final CompletableObserver observer)
Annotations
@Override