com.github.davidmoten.rx

Class Transformers

java.lang.Object

com.github.davidmoten.rx.Transformers

public final class Transformers
extends Object

Constructor Summary

Constructors

Constructor and Description
Transformers()

Method Summary

Methods

Modifier and Type	Method and Description
static <T> rx.Observable.Transformer<T,T>	bufferEmissions()
static <T> rx.Observable.Transformer<T,T>	bufferEmissions(rx.Scheduler scheduler)
static <T extends Number> rx.Observable.Transformer<T,Statistics>	collectStats()
static <T> rx.Observable.Transformer<T,MapWithIndex.Indexed<T>>	mapWithIndex()
static <T extends Comparable<T>> rx.Observable.Transformer<T,T>	sort()
static <T extends Comparable<T>> rx.Observable.Transformer<T,T>	sort(Comparator<T> comparator)
static <State,In,Out> rx.Observable.Transformer<In,Out>	stateMachine(rx.functions.Func0<State> initialState, rx.functions.Func3<State,In,rx.Observer<Out>,State> transition, rx.functions.Action2<State,rx.Observer<Out>> completionAction) Returns a Observable.Transformer that allows processing of the source stream to be defined in a state machine where transitions of the state machine may also emit items to downstream that are buffered if necessary when backpressure is requested.
static <State,In,Out> rx.Observable.Transformer<In,Out>	stateMachine(State initialState, rx.functions.Func3<State,In,rx.Observer<Out>,State> transition)
static <State,In,Out> rx.Observable.Transformer<In,Out>	stateMachine(State initialState, rx.functions.Func3<State,In,rx.Observer<Out>,State> transition, rx.functions.Action2<State,rx.Observer<Out>> completionAction)
static <T,R> rx.Observable.Operator<R,T>	toOperator(rx.functions.Func1<rx.Observable<T>,rx.Observable<R>> function)
static <T> rx.Observable.Transformer<T,Set<T>>	toSet()

Methods inherited from class java.lang.Object

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

Constructor Detail

Transformers

public Transformers()

Method Detail

toOperator

public static <T,R> rx.Observable.Operator<R,T> toOperator(rx.functions.Func1<rx.Observable<T>,rx.Observable<R>> function)

collectStats

public static <T extends Number> rx.Observable.Transformer<T,Statistics> collectStats()

sort

public static <T extends Comparable<T>> rx.Observable.Transformer<T,T> sort()

sort

public static <T extends Comparable<T>> rx.Observable.Transformer<T,T> sort(Comparator<T> comparator)

toSet

public static <T> rx.Observable.Transformer<T,Set<T>> toSet()

mapWithIndex

public static <T> rx.Observable.Transformer<T,MapWithIndex.Indexed<T>> mapWithIndex()

bufferEmissions

public static <T> rx.Observable.Transformer<T,T> bufferEmissions(rx.Scheduler scheduler)

stateMachine

public static <State,In,Out> rx.Observable.Transformer<In,Out> stateMachine(rx.functions.Func0<State> initialState,
                                                            rx.functions.Func3<State,In,rx.Observer<Out>,State> transition,
                                                            rx.functions.Action2<State,rx.Observer<Out>> completionAction)

Returns a Observable.Transformer that allows processing of the source stream to be defined in a state machine where transitions of the state machine may also emit items to downstream that are buffered if necessary when backpressure is requested. flatMap is part of the processing chain so the source may experience requests for more items than are strictly required by the endpoint subscriber.

Internally this transformer uses Observable.scan(rx.functions.Func2<T, T, T>) emitting a stream of new states composed with emissions from the transition to each state and Observable.flatMap(rx.functions.Func1<? super T, ? extends rx.Observable<? extends R>>) to emit the recorded emissions with backpressure.

Parameters:

initialState - the initial state of the state machine

transition - defines state transitions and consequent emissions to downstream when an item arrives from upstream

completionAction - defines activity that should happen based on the final state just before downstream onCompleted() is called. For example any buffered emissions in state could be emitted at this point. Don't call observer.onCompleted() as it is called for you after the action completes. .

Returns:

a backpressure supporting Transformation that implements the state machine specified by the parameters

stateMachine

public static <State,In,Out> rx.Observable.Transformer<In,Out> stateMachine(State initialState,
                                                            rx.functions.Func3<State,In,rx.Observer<Out>,State> transition,
                                                            rx.functions.Action2<State,rx.Observer<Out>> completionAction)

stateMachine

public static <State,In,Out> rx.Observable.Transformer<In,Out> stateMachine(State initialState,
                                                            rx.functions.Func3<State,In,rx.Observer<Out>,State> transition)

bufferEmissions

public static <T> rx.Observable.Transformer<T,T> bufferEmissions()