RxJava非同期キャッシュ：replay（）を処分する適切な方法です。autoConnect（）Observable

Question

私はobservableの結果に対して短命のキャッシュを提供する必要があります。

オプションを見て、私は次を参照してください。

1. キャッシュreplay(1).refCount()とデータの準備ができたときに、実際の値をキャッシュします。 キャッシュ取得は実際のデータをチェックし、Observable.justを返すか、 を返します。

2. キャッシュreplay(1).autoConnect(1)、いつもは

後者はよりまっすぐ進むと思われるが、それはキャッシュを無効にする必要があるときに正しく、観察処分する方法を1回の警告を、持っていること。戻ります

署名があります：

public Observable<T> autoConnect(int numberOfSubscribers, Consumer<? super Disposable> connection)

が、ハード、私は優秀なサブスクリプションを追跡することができますし、処分するか否かが優雅になりますどのように伝えるためには。

元はリソースの割り当てを処理しますが、より複雑なロジックを生成する必要があります。

Answer 1

なぜわからない.cache()？

public class CachedObservable<K,V> { 
    private Function<K, Observable<V>> actual; 
    private CachedObservable(Function<K, Observable<V>> actual){this.actual=actual;} 
    private final Map<K, Observable<V>> cacheMap = new ConcurrentHashMap<>(); 

    public Observable<V> get(K key) { 
    return cacheMap.computeIfAbsent(key, k -> this.actual.call(k).cache()); 
    } 
    public void invalidate(K key){cacheMap.remove(key);} 
}