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

public final Class FlowableConcatMapCompletable<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
FlowableConcatMapCompletable.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 Flowable<T>
source

Constructor Summary

AccessConstructor and Description
public
FlowableConcatMapCompletable(Flowable<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 Flowable<T> source

Constructor Detail

FlowableConcatMapCompletableback to summary
public FlowableConcatMapCompletable(Flowable<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 FlowableConcatMapCompletable.ConcatMapCompletableObserver<T>

extends ConcatMapXMainSubscriber<T>
implements Disposable
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.disposables.Disposable

Nested and Inner Type Summary

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

Field Summary

Modifier and TypeField and Description
pack-priv volatile boolean
active

pack-priv int
consumed

pack-priv final CompletableObserver
downstream

pack-priv final FlowableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
inner

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

private static final long
serialVersionUID

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

Inherited from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber:
cancelleddoneerrorModeerrorsprefetchqueuesyncFusedupstream

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
public void
dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
pack-priv void
disposeInner()

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

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

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

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

pack-priv void
innerError(Throwable ex)

public boolean
isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
pack-priv void
onSubscribeDownstream()

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

Typically, this should be downstream.onSubscribe(this);.
Inherited from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber:
clearValueonCompleteonErroronNextonSubscribestop

Field Detail

activeback to summary
pack-priv volatile boolean active
consumedback to summary
pack-priv int consumed
downstreamback to summary
pack-priv final CompletableObserver downstream
innerback to summary
pack-priv final FlowableConcatMapCompletable.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.ConcatMapXMainSubscriber.serialVersionUID.

Constructor Detail

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

Method Detail

disposeback to summary
public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
disposeInnerback to summary
pack-priv void disposeInner()

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

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

Typically, this should be inner.dispose().

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

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

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber.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)
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override
onSubscribeDownstreamback to summary
pack-priv void onSubscribeDownstream()

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

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

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

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

pack-priv final Class FlowableConcatMapCompletable.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 FlowableConcatMapCompletable.ConcatMapCompletableObserver<?>
parent

private static final long
serialVersionUID

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

Constructor Summary

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

Field Detail

parentback to summary
pack-priv final FlowableConcatMapCompletable.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(FlowableConcatMapCompletable.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