Bộ đệm không đồng bộ RxJava: cách thích hợp để vứt bỏ replay(). AutoConnect() Quan sát

Question

Tôi phải cung cấp bộ nhớ cache ngắn để có kết quả quan sát được.

Nhìn vào các tùy chọn và tôi thấy như sau:

1. bộ nhớ cache replay(1).refCount() và khi dữ liệu đã sẵn sàng, bộ nhớ cache giá trị thực tế. Truy xuất bộ nhớ cache sẽ kiểm tra dữ liệu thực tế và thực hiện Observable.just hoặc trả về đang chờ xử lý hoặc có thể bắt đầu yêu cầu mới.

2. bộ nhớ cache replay(1).autoConnect(1) và luôn luôn trả rằng

sau có vẻ thẳng về phía trước, nhưng nó có một ngoại, làm thế nào để xử lý một cách chính xác quan sát khi bộ nhớ cache đã hết hiệu lực.

Có một chữ ký:

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

nhưng khó có thể nói thế nào tôi có thể theo dõi đăng ký lưu hành và có hoặc không xử lý sẽ duyên dáng.

trước đây sẽ xử lý việc phân bổ tài nguyên, nhưng bạn phải tạo ra logic phức tạp hơn.

Answer 1

Tại sao không .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);} 
}