com.github.davidmoten.rx2

Class Flowables

java.lang.Object

com.github.davidmoten.rx2.Flowables

public final class Flowables
extends Object

Method Summary

Modifier and Type	Method and Description
static <T> CachedFlowable<T>	cache(io.reactivex.Flowable<T> source) Returns a cached Flowable like Flowable.cache() except that the cache can be reset by calling CachedFlowable.reset().
static <T> io.reactivex.Flowable<T>	cache(io.reactivex.Flowable<T> source, long duration, TimeUnit unit, io.reactivex.Scheduler.Worker worker) Returns a cached Flowable like Flowable.cache() except that the cache can be reset by calling CachedFlowable.reset() and the cache will be automatically reset an interval after first subscription (or first subscription after reset).
static <T> CloseableFlowableWithReset<T>	cache(io.reactivex.Flowable<T> source, long duration, TimeUnit unit, io.reactivex.Scheduler scheduler) Returns a cached Flowable like Flowable.cache() except that the cache may be reset by the user calling CloseableFlowableWithReset.reset().
static <T> io.reactivex.Flowable<T>	fetchPagesByRequest(io.reactivex.functions.BiFunction<? super Long,? super Long,? extends io.reactivex.Flowable<T>> fetch)
static <T> io.reactivex.Flowable<T>	fetchPagesByRequest(io.reactivex.functions.BiFunction<? super Long,? super Long,? extends io.reactivex.Flowable<T>> fetch, long start)
static <T> io.reactivex.Flowable<T>	fetchPagesByRequest(io.reactivex.functions.BiFunction<? super Long,? super Long,? extends io.reactivex.Flowable<T>> fetch, long start, int maxConcurrent)
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)
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 <T> io.reactivex.Flowable<T>	repeat(T t)
static <T> io.reactivex.Flowable<T>	repeat(T t, long count)

Methods inherited from class java.lang.Object

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

Method Detail

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)

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)

repeat

public static <T> io.reactivex.Flowable<T> repeat(T t)

repeat

public static <T> io.reactivex.Flowable<T> repeat(T t,
                                                  long count)

fetchPagesByRequest

public static <T> io.reactivex.Flowable<T> fetchPagesByRequest(io.reactivex.functions.BiFunction<? super Long,? super Long,? extends io.reactivex.Flowable<T>> fetch,
                                                               long start,
                                                               int maxConcurrent)

fetchPagesByRequest

public static <T> io.reactivex.Flowable<T> fetchPagesByRequest(io.reactivex.functions.BiFunction<? super Long,? super Long,? extends io.reactivex.Flowable<T>> fetch,
                                                               long start)

fetchPagesByRequest

public static <T> io.reactivex.Flowable<T> fetchPagesByRequest(io.reactivex.functions.BiFunction<? super Long,? super Long,? extends io.reactivex.Flowable<T>> fetch)

cache

public static <T> CachedFlowable<T> cache(io.reactivex.Flowable<T> source)

Returns a cached Flowable like Flowable.cache() except that the cache can be reset by calling CachedFlowable.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> io.reactivex.Flowable<T> cache(io.reactivex.Flowable<T> source,
                                                 long duration,
                                                 TimeUnit unit,
                                                 io.reactivex.Scheduler.Worker worker)

Returns a cached Flowable like Flowable.cache() except that the cache can be reset by calling CachedFlowable.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> CloseableFlowableWithReset<T> cache(io.reactivex.Flowable<T> source,
                                                      long duration,
                                                      TimeUnit unit,
                                                      io.reactivex.Scheduler scheduler)

Returns a cached Flowable like Flowable.cache() except that the cache may be reset by the user calling CloseableFlowableWithReset.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:

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