Ar naudojant zip operatorių RxJava užtikrinama duomenų srautų vienalaikė vykdymas?

RxJava operatorius zip negarantuoja duomenų srautų vienalaikio (paralelinio) vykdymo. Jis sujungia kelių Observable elementus, laukdamas, kol kiekvienas iš jų išleis savo kitą elementą, ir tada sujungia šiuos elementus į vieną.

Svarbu:

• zip sinchronizuoja srautus pagal elementus, tai yra, jis laukia, kol visi šaltiniai pateiks elementą toje pačioje pozicijoje.
• Srautai gali būti vykdomi sekliškai arba paraleliai priklausomai nuo planuotojo (Scheduler), tačiau zip pats jų neįjungia į paralelę.

Jei reikalingas paralelinis vykdymas, būtina aiškiai naudoti tinkamus operatorius ir planuotojus, pavyzdžiui, subscribeOn(Schedulers.io()).

Pavyzdys:

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

Čia srautai gali būti vykdomi paraleliai dėka subscribeOn, tačiau zip lauks, kol abu išleis savo elementus, kad juos sujungtų.