I have an array of Observable, each potentially producing the same elements. Then, I use flatMap()
to merge all of the observables, and subscribe to the resulting Observable:
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: ???"));
How do I need to change the code so I can determine which Observable emitted each item in the subscribe()
clause?
How about: