Identifica l'emissione di osservabili in RxJava

Question

Ho una serie di Observable, ognuno dei quali potenzialmente produce gli stessi elementi. Quindi, utilizzo flatMap()per unire tutti gli osservabili e mi iscrivo all'osservabile risultante:

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: ???"));

Come devo modificare il codice in modo da poter determinare quale Observable ha emesso ogni elemento nella subscribe()clausola?

Answer 1

Che ne dite di:

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