com.github.davidmoten.rx

Class Functions

java.lang.Object

com.github.davidmoten.rx.Functions

public final class Functions
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
static <T> rx.functions.Func1<T,Boolean>	alwaysFalse()
static <T> rx.functions.Func1<T,Boolean>	alwaysTrue()
static <T,R> rx.functions.Func1<T,R>	constant(R r)
static <T> rx.functions.Func1<T,T>	identity()
static <T> rx.functions.Func1<Iterable<T>,rx.Observable<T>>	iterableToObservable()
static <T> rx.functions.Func1<T,rx.Observable<T>>	just()
static <T> rx.functions.Func1<T,Boolean>	not(rx.functions.Func1<T,Boolean> f)
static <T> rx.functions.Func1<T,rx.Observable<T>>	parallel(rx.Scheduler scheduler) Returns a function that is expected to be used for performing parallel processing of an observable sequence via flatMap for instance.

Methods inherited from class java.lang.Object

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

Method Detail

identity

public static <T> rx.functions.Func1<T,T> identity()

alwaysTrue

public static <T> rx.functions.Func1<T,Boolean> alwaysTrue()

alwaysFalse

public static <T> rx.functions.Func1<T,Boolean> alwaysFalse()

constant

public static <T,R> rx.functions.Func1<T,R> constant(R r)

not

public static <T> rx.functions.Func1<T,Boolean> not(rx.functions.Func1<T,Boolean> f)

parallel

public static <T> rx.functions.Func1<T,rx.Observable<T>> parallel(rx.Scheduler scheduler)

Returns a function that is expected to be used for performing parallel processing of an observable sequence via flatMap for instance. For example:

source.flatMap(parallel(Schedulers.computation()));

Parameters:

scheduler - to be used for subscription to the function input

Returns:

each t is mapped to a single element observable using the given Scheduler for subscription

just

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

iterableToObservable

public static <T> rx.functions.Func1<Iterable<T>,rx.Observable<T>> iterableToObservable()