com.github.davidmoten.rx2

Class FlowableTransformers

java.lang.Object

com.github.davidmoten.rx2.FlowableTransformers

public final class FlowableTransformers
extends Object

Method Summary

Modifier and Type	Method and Description
static <T extends Number> io.reactivex.FlowableTransformer<T,Statistics>	collectStats()
static <T,R extends Number> io.reactivex.FlowableTransformer<T,Pair<T,Statistics>>	collectStats(io.reactivex.functions.Function<? super T,? extends R> function)
static <T> io.reactivex.FlowableTransformer<T,T>	doOnEmpty(io.reactivex.functions.Action action)
static <T> io.reactivex.FlowableTransformer<T,T>	mapLast(io.reactivex.functions.Function<? super T,? extends T> function)
static <A,B,K,C> io.reactivex.Flowable<C>	match(io.reactivex.Flowable<A> a, io.reactivex.Flowable<B> b, io.reactivex.functions.Function<? super A,K> aKey, io.reactivex.functions.Function<? super B,K> bKey, io.reactivex.functions.BiFunction<? super A,? super B,C> combiner, int requestSize)
static <A,B,C,K> io.reactivex.FlowableTransformer<A,C>	matchWith(io.reactivex.Flowable<B> b, io.reactivex.functions.Function<? super A,K> aKey, io.reactivex.functions.Function<? super B,K> bKey, io.reactivex.functions.BiFunction<? super A,? super B,C> combiner)
static <A,B,C,K> io.reactivex.FlowableTransformer<A,C>	matchWith(io.reactivex.Flowable<B> b, io.reactivex.functions.Function<? super A,K> aKey, io.reactivex.functions.Function<? super B,K> bKey, io.reactivex.functions.BiFunction<? super A,? super B,C> combiner, int requestSize)
static Options.BuilderFlowable	onBackpressureBufferToFile()
static <T> io.reactivex.FlowableTransformer<T,T>	reverse()
static StateMachine.Builder	stateMachine()
static <State,In,Out> io.reactivex.FlowableTransformer<In,Out>	stateMachine(Callable<? extends State> initialState, io.reactivex.functions.Function3<? super State,? super In,? super io.reactivex.FlowableEmitter<Out>,? extends State> transition, io.reactivex.functions.BiPredicate<? super State,? super io.reactivex.FlowableEmitter<Out>> completion, io.reactivex.BackpressureStrategy backpressureStrategy, int requestBatchSize)

Methods inherited from class java.lang.Object

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

Method Detail

stateMachine

public static <State,In,Out> io.reactivex.FlowableTransformer<In,Out> stateMachine(Callable<? extends State> initialState,
                                                                                   io.reactivex.functions.Function3<? super State,? super In,? super io.reactivex.FlowableEmitter<Out>,? extends State> transition,
                                                                                   io.reactivex.functions.BiPredicate<? super State,? super io.reactivex.FlowableEmitter<Out>> completion,
                                                                                   io.reactivex.BackpressureStrategy backpressureStrategy,
                                                                                   int requestBatchSize)

stateMachine

public static StateMachine.Builder stateMachine()

doOnEmpty

public static <T> io.reactivex.FlowableTransformer<T,T> doOnEmpty(io.reactivex.functions.Action action)

reverse

public static <T> io.reactivex.FlowableTransformer<T,T> reverse()

mapLast

public static <T> io.reactivex.FlowableTransformer<T,T> mapLast(io.reactivex.functions.Function<? super T,? extends T> function)

match

public static <A,B,K,C> io.reactivex.Flowable<C> match(io.reactivex.Flowable<A> a,
                                                       io.reactivex.Flowable<B> b,
                                                       io.reactivex.functions.Function<? super A,K> aKey,
                                                       io.reactivex.functions.Function<? super B,K> bKey,
                                                       io.reactivex.functions.BiFunction<? super A,? super B,C> combiner,
                                                       int requestSize)

matchWith

public static <A,B,C,K> io.reactivex.FlowableTransformer<A,C> matchWith(io.reactivex.Flowable<B> b,
                                                                        io.reactivex.functions.Function<? super A,K> aKey,
                                                                        io.reactivex.functions.Function<? super B,K> bKey,
                                                                        io.reactivex.functions.BiFunction<? super A,? super B,C> combiner,
                                                                        int requestSize)

matchWith

public static <A,B,C,K> io.reactivex.FlowableTransformer<A,C> matchWith(io.reactivex.Flowable<B> b,
                                                                        io.reactivex.functions.Function<? super A,K> aKey,
                                                                        io.reactivex.functions.Function<? super B,K> bKey,
                                                                        io.reactivex.functions.BiFunction<? super A,? super B,C> combiner)

onBackpressureBufferToFile

public static Options.BuilderFlowable onBackpressureBufferToFile()

collectStats

public static <T extends Number> io.reactivex.FlowableTransformer<T,Statistics> collectStats()

collectStats

public static <T,R extends Number> io.reactivex.FlowableTransformer<T,Pair<T,Statistics>> collectStats(io.reactivex.functions.Function<? super T,? extends R> function)