RxJavaでリポジトリパターンを実装する

Question

私はAndroidのRxJavaでリポジトリパターンのようなものを実現するためのより良い方法を見つけようとしています。ここで

は、私がこれまで持っているものだ。それはネットワーク要求を作ってあげるいない場合は、保存されたキャッシュされたデータがあるかどう基本的にはチェック

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; 
} 

を（hereからいくつかのコードを取りました）。また、それは常にネットワーク要求を行うrefreshブールパラメータ強制している。

この関数の呼び出し元は、Observableの代わりにSubscriptionを受け取る必要があります。これはもはやチェーンできません。

ファンクションを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; 
}