L'uso dell'operatore zip in RxJava garantisce l'esecuzione simultanea dei flussi di dati?

L'operatore zip in RxJava non garantisce l'esecuzione simultanea (parallela) dei flussi di dati. Combina gli elementi di più Observable aspettando che ciascuno emetta il suo elemento successivo, quindi unisce questi elementi in uno solo.

Importante:

• zip sincronizza i flussi per elemento, cioè aspetta che tutte le fonti forniscano un elemento alla stessa posizione.
• I flussi possono essere eseguiti in modo sequenziale o parallelo a seconda dello scheduler, ma zip di per sé non li avvia in parallelo.

Se è necessaria un'esecuzione parallela, bisogna usare esplicitamente gli operatori e gli scheduler appropriati, ad esempio subscribeOn(Schedulers.io()).

Esempio:

Observable<Integer> obs1 = Observable.just(1, 2, 3).subscribeOn(Schedulers.computation());
Observable<String> obs2 = Observable.just("A", "B", "C").subscribeOn(Schedulers.io());

Observable.zip(obs1, obs2, (num, str) -> num + str)
    .subscribe(System.out::println);

Qui, i flussi possono essere eseguiti in parallelo grazie a subscribeOn, ma zip aspetterà che entrambi emettano i loro elementi per combinarli.