RxJava Single.concat

Question

Ich habe den folgenden Code:

model.getCategories() 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Action1<List<Category>>() 
       { 
        @Override 
        public void call(final List<Category> categories) 
        { 
         model.getUnits() 
           .subscribeOn(Schedulers.io()) 
           .observeOn(AndroidSchedulers.mainThread()) 
           .subscribe(new Action1<List<Unit>>() 
           { 
            @Override 
            public void call(List<Unit> units) 
            { 
             view.showAddProductDialog(units, categories); 
            } 
           }); 
        } 
       }); 

Ich habe diese hässliche Verschachtelung. Wie kann ich es reparieren. Ich habe versucht, so etwas wie diese:

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

Aber das Problem ist, dass ich kann nicht bestimmt, ob es sich List<Category> oder List<Unit> kommt.

Gibt es eine Möglichkeit, concat zu verwenden und festzustellen, welche Art von Stream kommt (List<Category> oder List<Unit> oder etwas anderes)?

Auch ich muss erkennen, dass alle Beobachter abgeschlossen sind, um eine weitere Aktion durchzuführen.

Danke in Beratung.

Answer 1

Verwenden Single.zip():

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()) 
) 

wo Pair kann jedes Tupel Implementierung sein, d.h. this.