com.finovertech.rxjava.cache

Class ObservableCache<K,V>

java.lang.Object

com.finovertech.rxjava.cache.ObservableCache<K,V>

Type Parameters:

K - key

V - value

public final class ObservableCache<K,V>
extends java.lang.Object

Generic dataCache to asynchronous Rx Singles.

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_LOADING_CACHE_EXPIRY_IN_SECONDS
static long	DEFAULT_LOADING_CACHE_SIZE_LIMIT

Constructor Summary

Constructors

Constructor and Description
ObservableCache(com.google.common.cache.Cache<K,java.util.List<V>> dataCache, rx.functions.Func1<K,rx.Observable<V>> loader)
ObservableCache(com.google.common.cache.Cache<K,java.util.List<V>> dataCache, rx.functions.Func1<K,rx.Observable<V>> loader, long loadingCacheExpiryDuration, java.util.concurrent.TimeUnit loadingCacheExpiryTimeUnit, long loadingCacheSizeLimit)

Method Summary

Modifier and Type	Method and Description
rx.Observable<V>	get(K key)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LOADING_CACHE_EXPIRY_IN_SECONDS

public static final long DEFAULT_LOADING_CACHE_EXPIRY_IN_SECONDS

See Also:

Constant Field Values

DEFAULT_LOADING_CACHE_SIZE_LIMIT

public static final long DEFAULT_LOADING_CACHE_SIZE_LIMIT

See Also:

Constant Field Values

Constructor Detail

ObservableCache

public ObservableCache(com.google.common.cache.Cache<K,java.util.List<V>> dataCache,
                       rx.functions.Func1<K,rx.Observable<V>> loader)

ObservableCache

public ObservableCache(com.google.common.cache.Cache<K,java.util.List<V>> dataCache,
                       rx.functions.Func1<K,rx.Observable<V>> loader,
                       long loadingCacheExpiryDuration,
                       java.util.concurrent.TimeUnit loadingCacheExpiryTimeUnit,
                       long loadingCacheSizeLimit)

Method Detail

get

public rx.Observable<V> get(K key)