com.github.davidmoten.rx

Class RxUtil

java.lang.Object

com.github.davidmoten.rx.RxUtil

public final class RxUtil
extends Object

Utility methods for RxJava.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RxUtil.CountingAction<T>

Method Summary

Methods

Modifier and Type	Method and Description
static <T> rx.Observable.Operator<T,rx.Observable<T>>	concat()
static <T> rx.Observable<T>	concatButIgnoreFirstSequence(rx.Observable<?> o1, rx.Observable<T> o2) Returns the concatenation of two Observables but the first sequence will be emitted in its entirety and ignored before o2 starts emitting.
static <R,S> rx.functions.Func1<R,S>	constant(S s) Returns a constant value.
static <T> RxUtil.CountingAction<T>	counter() Returns an Action1 that increments a counter when the call method is called.
static <T> UnsubscribeDetector<T>	detectUnsubscribe() Returns a detector of unsubscribe events.
static <T> rx.Observable.Operator<T,rx.Observable<T>>	flatten() Returns an Observable.Operator that flattens a sequence of Observable into a flat sequence of the items from the Observables.
static <T extends Number> rx.functions.Func1<T,Boolean>	greaterThanZero()
static <T> rx.Observer<? super T>	log() Logs errors and onNext at info level using slf4j Logger.
static <T> rx.functions.Func1<T,rx.Observable<Object>>	toEmpty() Returns a Func1 that returns an empty Observable.
static <R,T> rx.Observable.Operator<R,T>	toOperator(rx.functions.Func1<rx.Observable<T>,rx.Observable<R>> operation) Converts a transformation of an Observable into another Observable into an Observable.Operator suitable for use with Observable.lift(Operator) for instance.

Methods inherited from class java.lang.Object

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

Method Detail

concatButIgnoreFirstSequence

public static <T> rx.Observable<T> concatButIgnoreFirstSequence(rx.Observable<?> o1,
                                                rx.Observable<T> o2)

Returns the concatenation of two Observables but the first sequence will be emitted in its entirety and ignored before o2 starts emitting.

Parameters:

o1 - the sequence to ignore

o2 - the sequence to emit after o1 ignored

Returns:

log

public static <T> rx.Observer<? super T> log()

Logs errors and onNext at info level using slf4j Logger.

Returns:

constant

public static <R,S> rx.functions.Func1<R,S> constant(S s)

Returns a constant value.

Parameters:

s -

Returns:

toOperator

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

Converts a transformation of an Observable into another Observable into an Observable.Operator suitable for use with Observable.lift(Operator) for instance.

Parameters:

operation -

Returns:

detectUnsubscribe

public static <T> UnsubscribeDetector<T> detectUnsubscribe()

Returns a detector of unsubscribe events. Insert this operator using lift just after the Observable you want to monitor unsubscribe on.

Returns:

counter

public static <T> RxUtil.CountingAction<T> counter()

Returns an Action1 that increments a counter when the call method is called.

Returns:

Action1 to count calls.

greaterThanZero

public static <T extends Number> rx.functions.Func1<T,Boolean> greaterThanZero()

toEmpty

public static <T> rx.functions.Func1<T,rx.Observable<Object>> toEmpty()

Returns a Func1 that returns an empty Observable.

Returns:

flatten

public static <T> rx.Observable.Operator<T,rx.Observable<T>> flatten()

Returns an Observable.Operator that flattens a sequence of Observable into a flat sequence of the items from the Observables. This operator may interleave the items asynchronously. For synchronous behaviour use concat().

Returns:

concat

public static <T> rx.Observable.Operator<T,rx.Observable<T>> concat()