Package hu.akarnokd.rxjava3.operators
Class CompletableTransformers
- java.lang.Object
-
- hu.akarnokd.rxjava3.operators.CompletableTransformers
-
public final class CompletableTransformers extends java.lang.ObjectAdditional operators in the form ofCompletableTransformer, useCompletable.compose(CompletableTransformer)to apply the operators to an existing sequence.- Since:
- 0.20.2
- See Also:
Completables
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static CompletableTransformerflatMap(Supplier<? extends CompletableSource> onCompleteHandler, Function<? super java.lang.Throwable,? extends CompletableSource> onErrorHandler)Maps the terminal signals of the upstream intoCompletableSources and subscribes to it, relaying its terminal events to the downstream.
-
-
-
Method Detail
-
flatMap
public static CompletableTransformer flatMap(Supplier<? extends CompletableSource> onCompleteHandler, Function<? super java.lang.Throwable,? extends CompletableSource> onErrorHandler)
Maps the terminal signals of the upstream intoCompletableSources and subscribes to it, relaying its terminal events to the downstream.- Parameters:
onCompleteHandler- called when the upstream completes normally and should return the CompletableSource to continue with.onErrorHandler- called when the upstream fails and should return the CompletableSource for the given Throwable instance to continue with.- Returns:
- the new CompletableTransformer instance
- Since:
- 0.20.2
-
-