com.github.davidmoten.rx2.flowable

Class Transformers

java.lang.Object

com.github.davidmoten.rx2.flowable.Transformers

public final class Transformers
extends Object

Method Summary

Modifier and Type	Method and Description
static <T> io.reactivex.FlowableTransformer<T,List<T>>	bufferWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition)
static <T> io.reactivex.FlowableTransformer<T,List<T>>	bufferWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition, boolean emitRemainder)
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,R> io.reactivex.FlowableTransformer<T,R>	collectWhile(Callable<R> collectionFactory, io.reactivex.functions.BiFunction<? super R,? super T,? extends R> add, io.reactivex.functions.BiPredicate<? super R,? super T> condition)
static <T,R> io.reactivex.FlowableTransformer<T,R>	collectWhile(Callable<R> collectionFactory, io.reactivex.functions.BiFunction<? super R,? super T,? extends R> add, io.reactivex.functions.BiPredicate<? super R,? super T> condition, boolean emitRemainder)
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 <T> io.reactivex.FlowableTransformer<T,T>	maxRequest(long... maxRequest)
static <T> io.reactivex.FlowableTransformer<T,T>	minRequest(int... minRequests)
static Options.BuilderFlowable	onBackpressureBufferToFile()
static <T> io.reactivex.FlowableTransformer<T,T>	rebatchRequests(int minRequest, long maxRequest)
static <T> io.reactivex.FlowableTransformer<T,T>	rebatchRequests(int minRequest, long maxRequest, boolean constrainFirstRequestMin)
static <T> io.reactivex.functions.Function<io.reactivex.Flowable<T>,io.reactivex.Flowable<T>>	reduce(io.reactivex.functions.Function<? super io.reactivex.Flowable<T>,? extends io.reactivex.Flowable<T>> reducer, int maxChained)
static <T> io.reactivex.functions.Function<io.reactivex.Flowable<T>,io.reactivex.Flowable<T>>	reduce(io.reactivex.functions.Function<? super io.reactivex.Flowable<T>,? extends io.reactivex.Flowable<T>> reducer, int maxChained, long maxIterations)
static <T> io.reactivex.functions.Function<io.reactivex.Flowable<T>,io.reactivex.Flowable<T>>	repeat(io.reactivex.functions.Function<? super io.reactivex.Flowable<T>,? extends io.reactivex.Flowable<T>> transform, int maxChained, long maxIterations, io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Observable<?>> tester)
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)
static StateMachine2.Builder	stateMachine2()
static <T> io.reactivex.FlowableTransformer<T,List<T>>	toListWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition)
static <T> io.reactivex.FlowableTransformer<T,List<T>>	toListWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition, boolean emitRemainder)
static <T extends Comparable<T>> io.reactivex.FlowableTransformer<T,T>	windowMax(int windowSize)
static <T> io.reactivex.FlowableTransformer<T,T>	windowMax(int windowSize, Comparator<? super T> comparator)
static <T extends Comparable<T>> io.reactivex.FlowableTransformer<T,T>	windowMin(int windowSize)
static <T> io.reactivex.FlowableTransformer<T,T>	windowMin(int windowSize, Comparator<? super T> comparator)

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()

stateMachine2

public static StateMachine2.Builder stateMachine2()

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)

collectWhile

public static <T,R> io.reactivex.FlowableTransformer<T,R> collectWhile(Callable<R> collectionFactory,
                                                                       io.reactivex.functions.BiFunction<? super R,? super T,? extends R> add,
                                                                       io.reactivex.functions.BiPredicate<? super R,? super T> condition,
                                                                       boolean emitRemainder)

collectWhile

public static <T,R> io.reactivex.FlowableTransformer<T,R> collectWhile(Callable<R> collectionFactory,
                                                                       io.reactivex.functions.BiFunction<? super R,? super T,? extends R> add,
                                                                       io.reactivex.functions.BiPredicate<? super R,? super T> condition)

toListWhile

public static <T> io.reactivex.FlowableTransformer<T,List<T>> toListWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition,
                                                                          boolean emitRemainder)

toListWhile

public static <T> io.reactivex.FlowableTransformer<T,List<T>> toListWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition)

bufferWhile

public static <T> io.reactivex.FlowableTransformer<T,List<T>> bufferWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition,
                                                                          boolean emitRemainder)

bufferWhile

public static <T> io.reactivex.FlowableTransformer<T,List<T>> bufferWhile(io.reactivex.functions.BiPredicate<? super List<T>,? super T> condition)

windowMax

public static <T extends Comparable<T>> io.reactivex.FlowableTransformer<T,T> windowMax(int windowSize)

windowMax

public static <T> io.reactivex.FlowableTransformer<T,T> windowMax(int windowSize,
                                                                  Comparator<? super T> comparator)

windowMin

public static <T extends Comparable<T>> io.reactivex.FlowableTransformer<T,T> windowMin(int windowSize)

windowMin

public static <T> io.reactivex.FlowableTransformer<T,T> windowMin(int windowSize,
                                                                  Comparator<? super T> comparator)

maxRequest

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

minRequest

public static <T> io.reactivex.FlowableTransformer<T,T> minRequest(int... minRequests)

rebatchRequests

public static <T> io.reactivex.FlowableTransformer<T,T> rebatchRequests(int minRequest,
                                                                        long maxRequest,
                                                                        boolean constrainFirstRequestMin)

rebatchRequests

public static <T> io.reactivex.FlowableTransformer<T,T> rebatchRequests(int minRequest,
                                                                        long maxRequest)

repeat

public static <T> io.reactivex.functions.Function<io.reactivex.Flowable<T>,io.reactivex.Flowable<T>> repeat(io.reactivex.functions.Function<? super io.reactivex.Flowable<T>,? extends io.reactivex.Flowable<T>> transform,
                                                                                                            int maxChained,
                                                                                                            long maxIterations,
                                                                                                            io.reactivex.functions.Function<io.reactivex.Observable<T>,io.reactivex.Observable<?>> tester)

reduce

public static <T> io.reactivex.functions.Function<io.reactivex.Flowable<T>,io.reactivex.Flowable<T>> reduce(io.reactivex.functions.Function<? super io.reactivex.Flowable<T>,? extends io.reactivex.Flowable<T>> reducer,
                                                                                                            int maxChained,
                                                                                                            long maxIterations)

reduce

public static <T> io.reactivex.functions.Function<io.reactivex.Flowable<T>,io.reactivex.Flowable<T>> reduce(io.reactivex.functions.Function<? super io.reactivex.Flowable<T>,? extends io.reactivex.Flowable<T>> reducer,
                                                                                                            int maxChained)