public final Class FlowableSwitchMapCompletablePublisher<T>

Class Inheritance

extends Completable

java.lang.Object
io.reactivex.rxjava3.core.Completable
io.reactivex.rxjava3.internal.operators.mixed.FlowableSwitchMapCompletablePublisher

Type Parameters

Imports

Switch between subsequent CompletableSources emitted by a Publisher. Reuses FlowableSwitchMapCompletable internals.

Field Summary

Modifier and Type	Field and Description
pack-priv final boolean	delayErrors
pack-priv final Function<? super T, ? extends CompletableSource>	mapper
pack-priv final Publisher<T>	source

Access	Constructor and Description
public	FlowableSwitchMapCompletablePublisher(Publisher<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors)

Modifier and Type	Method and Description
protected void	subscribeActual(CompletableObserver observer)

Inherited from io.reactivex.rxjava3.core.Completable:: amb ambArray ambWith andThen andThen andThen andThen andThen blockingAwait blockingAwait blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe cache complete compose concat concat concat concatArray concatArrayDelayError concatDelayError concatDelayError concatDelayError concatWith create defer delay delay delay delaySubscription delaySubscription doAfterTerminate doFinally doOnComplete doOnDispose doOnError doOnEvent doOnLifecycle doOnSubscribe doOnTerminate error error fromAction fromCallable fromCompletionStage fromFuture fromMaybe fromObservable fromPublisher fromRunnable fromSingle fromSupplier hide lift materialize merge merge merge mergeArray mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn onErrorComplete onErrorComplete onErrorResumeNext onErrorResumeWith onErrorReturn onErrorReturnItem onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryUntil retryWhen safeSubscribe sequenceEqual startWith startWith startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribeActual subscribeOn subscribeWith switchOnNext switchOnNextDelayError takeUntil test test timeout timeout timeout timeout timer timer to toCompletionStage toFlowable toFuture toMaybe toObservable toSingle toSingleDefault unsafeCreate unsubscribeOn using using wrap

delayErrors	back to summary
pack-priv final boolean delayErrors

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

source	back to summary
pack-priv final Publisher<T> source

FlowableSwitchMapCompletablePublisher	back to summary
public FlowableSwitchMapCompletablePublisher(Publisher<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors)

subscribeActual	back to summary
protected void subscribeActual(CompletableObserver observer) Annotations @Override