hu.akarnokd.rxjava2.operators

Class SingleTransformers

java.lang.Object

hu.akarnokd.rxjava2.operators.SingleTransformers

public final class SingleTransformers
extends java.lang.Object

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

Since:

0.20.2

See Also:

Singles

Method Summary

Modifier and Type	Method and Description
static <T,R> io.reactivex.SingleTransformer<T,R>	flatMap(io.reactivex.functions.Function<? super T,? extends io.reactivex.SingleSource<? extends R>> onSuccessHandler, io.reactivex.functions.Function<? super java.lang.Throwable,? extends io.reactivex.SingleSource<? extends R>> onErrorHandler) Maps the terminal signals of the upstream into SingleSources 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 <T,R> io.reactivex.SingleTransformer<T,R> flatMap(io.reactivex.functions.Function<? super T,? extends io.reactivex.SingleSource<? extends R>> onSuccessHandler,
                                                                io.reactivex.functions.Function<? super java.lang.Throwable,? extends io.reactivex.SingleSource<? extends R>> onErrorHandler)

Maps the terminal signals of the upstream into SingleSources and subscribes to it, relaying its terminal events to the downstream.

Type Parameters:

T - the success type of the upstream

R - the success type of the resulting Maybe

Parameters:

onSuccessHandler - a function called with the upstream success value and should return a SingleSource to continue with.

onErrorHandler - called when the upstream fails and should return the SingleSource for the given Throwable instance to continue with.

Returns:

the new SingleTransformer instance

Since:

0.20.2