Top Description Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.mixed

public final Class ObservableConcatMapCompletable<T>

extends Completable
Class Inheritance
Type Parameters
<T>
the upstream value type
Imports
java.util.Objects, java.util.concurrent.atomic.AtomicReference, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.internal.disposables.DisposableHelper, io.reactivex.rxjava3.internal.util.*, io.reactivex.rxjava3.operators.SimpleQueue
Maps the upstream items into CompletableSources and subscribes to them one after the other completes or terminates (in error-delaying mode).

History: 2.1.11 - experimental

Since
2.2

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>

Field Summary

Modifier and TypeField and Description
pack-priv final ErrorMode
errorMode

pack-priv final Function<? super T, ? extends CompletableSource>
mapper

pack-priv final int
prefetch

pack-priv final Observable<T>
source

Constructor Summary

AccessConstructor and Description
public
ObservableConcatMapCompletable(Observable<T> source, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)

Method Summary

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

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

Field Detail

errorModeback to summary
pack-priv final ErrorMode errorMode
mapperback to summary
pack-priv final Function<? super T, ? extends CompletableSource> mapper
prefetchback to summary
pack-priv final int prefetch
sourceback to summary
pack-priv final Observable<T> source

Constructor Detail

ObservableConcatMapCompletableback to summary
public ObservableConcatMapCompletable(Observable<T> source, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)

Method Detail

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

pack-priv final Class ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>

extends ConcatMapXMainObserver<T>
Class Inheritance

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver

Field Summary

Modifier and TypeField and Description
pack-priv volatile boolean
active

pack-priv final CompletableObserver
downstream

pack-priv final ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
inner

pack-priv final Function<? super T, ? extends CompletableSource>
mapper

private static final long
serialVersionUID

Hides io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.serialVersionUID.

Inherited from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver:
disposeddoneerrorModeerrorsprefetchqueueupstream

Constructor Summary

AccessConstructor and Description
pack-priv
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)

Method Summary

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

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.disposeInner.

Typically, this should be inner.dispose().
pack-priv void
drain()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.drain.

Implement the serialized inner subscribing and value emission here.
pack-priv void
innerComplete()

pack-priv void
innerError(Throwable ex)

pack-priv void
onSubscribeDownstream()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.onSubscribeDownstream.

Typically, this should be downstream.onSubscribe(this).
Inherited from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver:
clearValuedisposeisDisposedonCompleteonErroronNextonSubscribe

Field Detail

activeback to summary
pack-priv volatile boolean active
downstreamback to summary
pack-priv final CompletableObserver downstream
innerback to summary
pack-priv final ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver inner
mapperback to summary
pack-priv final Function<? super T, ? extends CompletableSource> mapper
serialVersionUIDback to summary
private static final long serialVersionUID

Hides io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.serialVersionUID.

Constructor Detail

ConcatMapCompletableObserverback to summary
pack-priv ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)

Method Detail

disposeInnerback to summary
pack-priv void disposeInner()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.disposeInner.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.disposeInner.

Typically, this should be inner.dispose().

Annotations
@Override
drainback to summary
pack-priv void drain()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.drain.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.drain.

Implement the serialized inner subscribing and value emission here.

Annotations
@Override
innerCompleteback to summary
pack-priv void innerComplete()
innerErrorback to summary
pack-priv void innerError(Throwable ex)
onSubscribeDownstreamback to summary
pack-priv void onSubscribeDownstream()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.onSubscribeDownstream.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.onSubscribeDownstream.

Typically, this should be downstream.onSubscribe(this).

Annotations
@Override
io.reactivex.rxjava3.internal.operators.mixed back to summary

pack-priv final Class ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver

extends AtomicReference<Disposable>
implements CompletableObserver
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.CompletableObserver

Field Summary

Modifier and TypeField and Description
pack-priv final ObservableConcatMapCompletable.ConcatMapCompletableObserver<?>
parent

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Summary

AccessConstructor and Description
pack-priv
ConcatMapInnerObserver(ObservableConcatMapCompletable.ConcatMapCompletableObserver<?> parent)

Field Detail

parentback to summary
pack-priv final ObservableConcatMapCompletable.ConcatMapCompletableObserver<?> parent
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Detail

ConcatMapInnerObserverback to summary
pack-priv ConcatMapInnerObserver(ObservableConcatMapCompletable.ConcatMapCompletableObserver<?> parent)

Method Detail

disposeback to summary
pack-priv void dispose()
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