Zabezpečuje použitie operátora zip v RxJava súčasné vykonávanie tokov dát?

Operator zip v RxJava nezaručuje súčasné (paralelné) vykonávanie tokov dát. Kombinuje prvky z viacerých Observable, čakajúc, kým každý z nich vydá svoj ďalší prvok, a potom tieto prvky spojí do jedného.

Dôležité:

• zip synchronizuje toky podľa prvkov, teda čaká, kým všetky zdroje poskytnú prvok na rovnakej pozícii.
• Toky môžu byť spustené sekvenčne alebo paralelne v závislosti od scheduler-a, ale zip ich sám o sebe nespúšťa paralelne.

Ak je potrebné paralelné vykonávanie, je nutné explicitne použiť príslušné operátory a scheduler-e, napríklad subscribeOn(Schedulers.io()).

Príklad:

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

Tu môžu byť toky spustené paralelne vďaka subscribeOn, ale zip bude čakať, kým obe emitujú svoje prvky, aby ich spojil.