RxJava Single.concat

Question

は、私は、次のコードを持っています。どうすれば修正できますか？ 私はこのような何か試してみました：

Single.concat(model.getCategories(), model.getUnits()) 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Action1<List<? extends Object>>() 
       { 
        @Override 
        public void call(List<? extends Object> objects) 
        { 
         // do something 
        } 
       }); 

をしかし、問題は、私はそれがList<Category>またはList<Unit>来ているかどうかを確定することができないということです。

concatを使用して、どのような種類のストリーム（List<Category>またはList<Unit>など）が来るかを検出する方法はありますか？

また、すべてのオブザーバが完了して別の操作を実行することを検出する必要があります。

アドバイスありがとうございます。

Answer 1

使用Single.zip()：Pair任意のタプル実装、すなわち、thisことができる

Single.zip(
    getCategories().subscribeOn(Schedulers.io()), 
    getUnits().subscribeOn(Schedulers.io()), 
    (a, b) -> Pair.of(a, b) 
) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(
    pair -> view.showAddProductDialog(pair.first, pair.second), 
    error -> showError(error.toString()) 
) 

。