Class FlowableFlatMapCompletableCompletable<T>
- java.lang.Object
-
- io.reactivex.rxjava3.core.Completable
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMapCompletableCompletable<T>
-
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
CompletableSource
,FuseToFlowable<T>
public final class FlowableFlatMapCompletableCompletable<T> extends Completable implements FuseToFlowable<T>
Maps a sequence of values into CompletableSources and awaits their termination.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber<T>
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
delayErrors
(package private) Function<? super T,? extends CompletableSource>
mapper
(package private) int
maxConcurrency
(package private) Flowable<T>
source
-
Constructor Summary
Constructors Constructor Description FlowableFlatMapCompletableCompletable(Flowable<T> source, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Flowable<T>
fuseToFlowable()
Returns a (direct) Flowable for the operator.protected void
subscribeActual(CompletableObserver observer)
Implement this method to handle the incomingCompletableObserver
s and perform the business logic in your operator.-
Methods inherited from class 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, 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
-
-
-
-
Field Detail
-
mapper
final Function<? super T,? extends CompletableSource> mapper
-
maxConcurrency
final int maxConcurrency
-
delayErrors
final boolean delayErrors
-
-
Constructor Detail
-
FlowableFlatMapCompletableCompletable
public FlowableFlatMapCompletableCompletable(Flowable<T> source, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency)
-
-
Method Detail
-
subscribeActual
protected void subscribeActual(CompletableObserver observer)
Description copied from class:Completable
Implement this method to handle the incomingCompletableObserver
s and perform the business logic in your operator.There is no need to call any of the plugin hooks on the current
Completable
instance or theCompletableObserver
; all hooks and basic safeguards have been applied byCompletable.subscribe(CompletableObserver)
before this method gets called.- Specified by:
subscribeActual
in classCompletable
- Parameters:
observer
- theCompletableObserver
instance, nevernull
-
fuseToFlowable
public Flowable<T> fuseToFlowable()
Description copied from interface:FuseToFlowable
Returns a (direct) Flowable for the operator.The implementation should handle the necessary RxJavaPlugins wrapping.
- Specified by:
fuseToFlowable
in interfaceFuseToFlowable<T>
- Returns:
- the Flowable instance
-
-