使用RxJava实现存储库模式

Question

我想找到一种更好的方式来实现类似RxJava中的存储库模式。

这是我到目前为止有：（采取了一些代码here）

public Subscription getData(Observer<Data> observer, boolean refresh) { 
    Subscription sub = null; 

    Data cached = getCachedData(); 
    if(cached != null) { 
     observer.onNext(cached); 
     if(refresh) { 
      sub = requestNetwork().subscribe(observer); 
     } else { 
      observer.onCompleted(); 
     } 
    } else { 
     sub = requestNetwork().subscribe(observer); 
    } 

    return sub; 
} 

基本上它检查是否有缓存存储的数据，如果没有它会发出一个网络请求。它也有refresh布尔参数强制它总是发出网络请求。

问题（或不是），此功能的调用者需要调用它将收到Subscription而不是Observable，我不能再链接。

有没有办法让函数返回Observable但仍然有存储库模式？

Answer 1

感谢akarnokd指出我由Dan Lew为this article。

我的最终代码：

public Observable<Data> getData(boolean refresh) { 
    Observable<Data> obs = Observable.concat(getCache(), requestNetwork()); 
    if(!refresh) { 
     obs = obs.first(data -> data != null); 
    } 
    return obs; 
}