src/main/java/io/reactivex/Flowable.java
@CheckReturnValue
    @NonNull
    @BackpressureSupport(BackpressureKind.UNBOUNDED_IN)
    @SchedulerSupport(SchedulerSupport.NONE)
    public final Completable switchMapCompletable(@NonNull Function<? super T, ? extends CompletableSource> mapper) {
        ObjectHelper.requireNonNull(mapper, "mapper is null");
        return RxJavaPlugins.onAssembly(new FlowableSwitchMapCompletable<T>(this, mapper, false));
    }
@CheckReturnValue
    @NonNull
    @BackpressureSupport(BackpressureKind.UNBOUNDED_IN)
    @SchedulerSupport(SchedulerSupport.NONE)
    public final Completable switchMapCompletable(@NonNull Function<? super T, ? extends CompletableSource> mapper) {
        ObjectHelper.requireNonNull(mapper, "mapper is null");
        return RxJavaPlugins.onAssembly(new FlowableSwitchMapCompletable<T>(this, mapper, false));
    }
@ CheckReturnValue @ NonNull @ BackpressureSupport ( BackpressureKind . UNBOUNDED_IN ) @ SchedulerSupport ( SchedulerSupport . NONE ) public final Completable switchMapCompletable ( @ NonNull Function < ? super T , ? extends CompletableSource > mapper ) { ObjectHelper . requireNonNull ( mapper , "mapper is null" ) ; return RxJavaPlugins . onAssembly ( new FlowableSwitchMapCompletable < T > ( this , mapper , false ) ) ; }
Maps the upstream values into {@link CompletableSource}s, subscribes to the newer one while
disposing the subscription to the previous {@code CompletableSource}, thus keeping at most one
active {@code CompletableSource} running.
<p>
<img width="640" height="521" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/switchMapCompletable.f.png" alt="">
<p>
Since a {@code CompletableSource} doesn't produce any items, the resulting reactive type of
this operator is a {@link Completable} that can only indicate successful completion or
a failure in any of the inner {@code CompletableSource}s or the failure of the current
{@link Flowable}.
<dl>
<dt><b>Backpressure:</b></dt>
<dd>The operator consumes the current {@link Flowable} in an unbounded manner and otherwise
does not have backpressure in its return type because no items are ever produced.</dd>
<dt><b>Scheduler:</b></dt>
<dd>{@code switchMapCompletable} does not operate by default on a particular {@link Scheduler}.</dd>
<dt><b>Error handling:</b></dt>
<dd>If either this {@code Flowable} or the active {@code CompletableSource} signals an {@code onError},
the resulting {@code Completable} is terminated immediately with that {@code Throwable}.
Use the {@link #switchMapCompletableDelayError(Function)} to delay such inner failures until
every inner {@code CompletableSource}s and the main {@code Flowable} terminates in some fashion.
If they fail concurrently, the operator may combine the {@code Throwable}s into a
{@link io.reactivex.exceptions.CompositeException CompositeException}
and signal it to the downstream instead. If any inactivated (switched out) {@code CompletableSource}
signals an {@code onError} late, the {@code Throwable}s will be signaled to the global error handler via
{@link RxJavaPlugins#onError(Throwable)} method as {@code UndeliverableException} errors.
</dd>
</dl>
<p>History: 2.1.11 - experimental
@param mapper the function called with each upstream item and should return a
{@link CompletableSource} to be subscribed to and awaited for
(non blockingly) for its terminal event
@return the new Completable instance
@see #switchMapCompletableDelayError(Function)
@since 2.2
Maps the upstream values into {