com.finovertech.rxjava.cache

Class ObservableOneOrNothingCache<K,V>

java.lang.Object

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

Type Parameters:

K - key

V - value

public final class ObservableOneOrNothingCache<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
ObservableOneOrNothingCache(com.google.common.cache.Cache<K,V> dataCache, rx.functions.Func1<K,rx.Observable<V>> loader)
ObservableOneOrNothingCache(com.google.common.cache.Cache<K,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

ObservableOneOrNothingCache

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

ObservableOneOrNothingCache

public ObservableOneOrNothingCache(com.google.common.cache.Cache<K,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)