RxJava異步緩存：正確的方式來處理重播（）。autoConnect（）Observable

Question

我必須爲observable的結果提供一個短暫的緩存。在選項

看，我看到以下內容：

1. 緩存replay(1).refCount()當數據準備好，緩存的實際值。 緩存檢索將檢查實際數據並執行Observable.just或返回 待定可觀察或啓動新的請求。

2. 緩存replay(1).autoConnect(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);} 
}