Identifier les observables émetteurs dans RxJava

Question

J'ai un tableau d'Observable, chacun produisant potentiellement les mêmes éléments. Ensuite, j'utilise flatMap()pour fusionner toutes les observables et m'abonner à l'Observable résultant:

Observable<Integer> o1 = Observable.range(0, 5);
Observable<Integer> o2 = Observable.range(0, 5);
Observable<Integer> o3 = Observable.range(0, 5);
        
Observable.fromArray(o1, o2, o3)
     .flatMap(o -> o)    // merge outputs from all observables
     .subscribe(item -> Log.i(TAG, "Item: " + item + " Observable id: ???"));

Comment dois-je changer le code afin de pouvoir déterminer quel Observable a émis chaque élément de la subscribe()clause?

Answer 1

Que diriez-vous:

Observable<Item> o1 = Observable.range(0, 5).map(i -> new Item(i, "o1"));
Observable<Item> o2 = Observable.range(0, 5).map(i -> new Item(i, "o2"));
Observable<Item> o3 = Observable.range(0, 5).map(i -> new Item(i, "o3"));