データベースとサーバーへのRxJavaチェーン

Question

良いチェーンを作成しようとしています。私はこの質問が人気であり、尋ねられたと思うが、私はそれを見つけられていない。

だから、私が望むのはデータベースに行くことです。その中に何かがなければ、サーバーから情報をダウンロードします。ここで

はコードです：

() -> loadPriceListFromDatabase.call(null) 
         .flatMap(mealTypes -> { 
          if (mealTypes.size() != 0) { 
           return Observable.just(mealTypes); //here is the place where I'm not sure about code style. 
          } 
          return loadPriceList.call(null) 
            .map(model -> { 
             preferences.setPriceListDate(model.getDate().getTime()); 
             return ActiveAndroidHelper.saveMeals(model); 
            }); 
         }) 
         .subscribeOn(Schedulers.io()) 
         .observeOn(AndroidSchedulers.mainThread()), 
       MainActivity::onTestLoaded, 
       BaseActivity::onError 

だから私はこれをどのようにしたらよいでしょうか？ はの例を使用する必要がありますか？

私は内部\ elseブロックであれば好きな条件を入れたい

UPD。

if (mealTypes.size() != 0) { 

何かがnullでもゼロでもない。 たとえば、私はあなたに観察が自動的にパイプラインで新しいものを提供することができ、空である場合には

if (date == currentDate) { (//where date is timestamp 

Answer 1

をチェックそれは同じくらい簡単です：それがない限りnetworkObservableに加入しません

Observable.concat(
    databaseObservable.filter(databaseItem -> databaseItem.date ==  currentDate) , 
    networkObservable 
).take(1).subscribe(...) 

databaseObservableはonNextなしで完了します。

Answer 2

使用swtichIfEmptyオペレータが、言うことができます。

チェックこの例

@Test 
public void testSwitchPerson() { 
    Observable.just(new ArrayList<>()) 
       .flatMap(persons -> Observable.from(persons) 
              .switchIfEmpty(Observable.just(new Person("new", 0, "no_sex")))) 
       .subscribe(System.out::println); 

} 

あなたはより実用的な例を参照したい場合はhttps://github.com/politrons/reactiveにここ