hu.akarnokd.rxjava2.operators

Class CompletableTransformers

java.lang.Object

hu.akarnokd.rxjava2.operators.CompletableTransformers

public final class CompletableTransformers
extends java.lang.Object

Additional operators in the form of CompletableTransformer, use Completable.compose(CompletableTransformer) to apply the operators to an existing sequence.

Since:

0.20.2

See Also:

Completables

Method Summary

Modifier and Type	Method and Description
static io.reactivex.CompletableTransformer	flatMap(java.util.concurrent.Callable<? extends io.reactivex.CompletableSource> onCompleteHandler, io.reactivex.functions.Function<? super java.lang.Throwable,? extends io.reactivex.CompletableSource> onErrorHandler) Maps the terminal signals of the upstream into CompletableSources and subscribes to it, relaying its terminal events to the downstream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

flatMap

public static io.reactivex.CompletableTransformer flatMap(java.util.concurrent.Callable<? extends io.reactivex.CompletableSource> onCompleteHandler,
                                                          io.reactivex.functions.Function<? super java.lang.Throwable,? extends io.reactivex.CompletableSource> onErrorHandler)

Maps the terminal signals of the upstream into CompletableSources 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