Da li korišćenje zip operatora u RxJava garantuje istovremeno izvršavanje tokova podataka?

Operator zip u RxJava ne garantuje istovremeno (paralelno) izvršavanje tokova podataka. Kombinuje elemente iz više Observable, čekajući da svaki od njih emitira sledeći element, a zatim te elemente spaja u jedan.

Važno:

• zip sinhronizuje tokove po elementima, tj. čeka da svi izvori dostave element na istoj poziciji.
• Tokovi mogu biti izvršeni sekvencijalno ili paralelno u zavisnosti od scheduler-a, ali zip sam po sebi ne pokreće ih paralelno.

Ako je potrebna paralelna izvršenja, potrebno je eksplicitno koristiti odgovarajuće operatore i scheduler-e, na primer, subscribeOn(Schedulers.io()).

Primer:

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

Ovde, tokovi mogu biti izvršeni paralelno zahvaljujući subscribeOn, ali zip će čekati da oba emitenta pošalju svoje elemente da bi ih spojio.