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

public final Class CompletableConcatIterable

extends Completable
Class Inheritance
Imports
java.util.Iterator, .Objects, java.util.concurrent.atomic.AtomicInteger, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.internal.disposables.*

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
CompletableConcatIterable.ConcatInnerObserver

Field Summary

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

Constructor Summary

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

Method Summary

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

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

Field Detail

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

Constructor Detail

CompletableConcatIterableback to summary
public CompletableConcatIterable(Iterable<? extends CompletableSource> sources)

Method Detail

subscribeActualback to summary
public void subscribeActual(CompletableObserver observer)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.completable back to summary

pack-priv final Class CompletableConcatIterable.ConcatInnerObserver

extends AtomicInteger
implements CompletableObserver
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.CompletableObserver

Field Summary

Modifier and TypeField and Description
pack-priv final CompletableObserver
downstream

pack-priv final SequentialDisposable
sd

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

pack-priv final Iterator<? extends CompletableSource>
sources

Constructor Summary

AccessConstructor and Description
pack-priv
ConcatInnerObserver(CompletableObserver actual, Iterator<? extends CompletableSource> sources)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
next()

public void
onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.
public void
onError(Throwable e)

public void
onSubscribe(Disposable d)

Inherited from java.util.concurrent.atomic.AtomicInteger:
accumulateAndGetaddAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetdecrementAndGetdoubleValuefloatValuegetgetAcquiregetAndAccumulategetAndAddgetAndDecrementgetAndIncrementgetAndSetgetAndUpdategetOpaquegetPlainincrementAndGetintValuelazySetlongValuesetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

downstreamback to summary
pack-priv final CompletableObserver downstream
sdback to summary
pack-priv final SequentialDisposable sd
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

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

Constructor Detail

ConcatInnerObserverback to summary
pack-priv ConcatInnerObserver(CompletableObserver actual, Iterator<? extends CompletableSource> sources)

Method Detail

nextback to summary
pack-priv void next()
onCompleteback to summary
public void onComplete()

Implements io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Doc from io.reactivex.rxjava3.core.CompletableObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)
Annotations
@Override