com.github.davidmoten.rx

Class Obs

java.lang.Object

com.github.davidmoten.rx.Obs

public final class Obs
extends Object

Constructor Summary

Constructors

Constructor and Description
Obs()

Method Summary

Modifier and Type	Method and Description
static <T> CachedObservable<T>	cache(rx.Observable<T> source) Returns a cached Observable like Observable.cache() except that the cache can be reset by calling CachedObservable.reset().
static <T> rx.Observable<T>	cache(rx.Observable<T> source, long duration, TimeUnit unit, rx.Scheduler.Worker worker) Returns a cached Observable like Observable.cache() except that the cache can be reset by calling CachedObservable.reset() and the cache will be automatically reset an interval after first subscription (or first subscription after reset).
static <T> CloseableObservableWithReset<T>	cache(rx.Observable<T> source, long duration, TimeUnit unit, rx.Scheduler scheduler) Returns a cached Observable like Observable.cache() except that the cache may be reset by the user calling CloseableObservableWithReset.reset().
static <T extends Comparable<? super T>> rx.Observable<T>	create(Collection<rx.Observable<T>> sources)
static <T extends Comparable<? super T>> rx.Observable<T>	create(Collection<rx.Observable<T>> sources, boolean delayErrors)
static <T> rx.Observable<T>	create(Collection<rx.Observable<T>> sources, Comparator<? super T> comparator)
static <T> rx.Observable<T>	create(Collection<rx.Observable<T>> sources, Comparator<? super T> comparator, boolean delayErrors)
static <T> rx.Observable<T>	fromQueue(Queue<T> queue)
static rx.Observable<Long>	intervalLong(long duration, TimeUnit unit)
static rx.Observable<Long>	intervalLong(long duration, TimeUnit unit, rx.Scheduler scheduler)
static <T> rx.Observable<List<Integer>>	permutations(int size)
static <T> rx.Observable<List<T>>	permutations(List<T> list)
static <T> rx.Observable<T>	repeating(T t) Returns an Observable that epeats emitting t without completing.

Methods inherited from class java.lang.Object

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

Constructor Detail

Obs

public Obs()

Method Detail

cache

public static <T> CachedObservable<T> cache(rx.Observable<T> source)

Returns a cached Observable like Observable.cache() except that the cache can be reset by calling CachedObservable.reset().

Type Parameters:

T - the generic type of the source

Parameters:

source - the observable to be cached.

Returns:

a cached observable whose cache can be reset.

cache

public static <T> rx.Observable<T> cache(rx.Observable<T> source,
                                         long duration,
                                         TimeUnit unit,
                                         rx.Scheduler.Worker worker)

Returns a cached Observable like Observable.cache() except that the cache can be reset by calling CachedObservable.reset() and the cache will be automatically reset an interval after first subscription (or first subscription after reset). The interval is defined by duration and unit .

Type Parameters:

T - the generic type of the source

Parameters:

source - the source observable

duration - duration till next reset

unit - units corresponding to the duration

worker - worker to use for scheduling reset. Don't forget to unsubscribe the worker when no longer required.

Returns:

cached observable that resets regularly on a time interval

cache

public static <T> CloseableObservableWithReset<T> cache(rx.Observable<T> source,
                                                        long duration,
                                                        TimeUnit unit,
                                                        rx.Scheduler scheduler)

Returns a cached Observable like Observable.cache() except that the cache may be reset by the user calling CloseableObservableWithReset.reset().

Type Parameters:

T - generic type of source observable

Parameters:

source - the source observable

duration - duration till next reset

unit - units corresponding to the duration

scheduler - scheduler to use for scheduling reset.

Returns:

CloseableObservableWithReset that should be closed once finished to prevent worker memory leak.

repeating

public static <T> rx.Observable<T> repeating(T t)

Returns an Observable that epeats emitting t without completing. Supports backpressure.

Type Parameters:

T - type of t

Parameters:

t - value to repeat

Returns:

an observable that repeats t forever (or until unsubscribed)

create

public static <T extends Comparable<? super T>> rx.Observable<T> create(Collection<rx.Observable<T>> sources)

create

public static <T> rx.Observable<T> create(Collection<rx.Observable<T>> sources,
                                          Comparator<? super T> comparator)

create

public static <T extends Comparable<? super T>> rx.Observable<T> create(Collection<rx.Observable<T>> sources,
                                                                        boolean delayErrors)

create

public static <T> rx.Observable<T> create(Collection<rx.Observable<T>> sources,
                                          Comparator<? super T> comparator,
                                          boolean delayErrors)

fromQueue

public static <T> rx.Observable<T> fromQueue(Queue<T> queue)

permutations

public static <T> rx.Observable<List<Integer>> permutations(int size)

permutations

public static <T> rx.Observable<List<T>> permutations(List<T> list)

intervalLong

public static rx.Observable<Long> intervalLong(long duration,
                                               TimeUnit unit,
                                               rx.Scheduler scheduler)

intervalLong

public static rx.Observable<Long> intervalLong(long duration,
                                               TimeUnit unit)