RxJava-ում zip օպերատորի օգտագործումը ապահովում է տվյալների հոսքերի միաժամանակյա կատարմամբը?

RxJava- ի zip օպերատորը չի ապահովում տվյալների հոսքերի միաժամանակյա (պարալել) կատարմամբը։ Այն համակցում է մի քանի Observable-ներից տարրերը՝ սպասելով, որ յուրաքանչյուրը կհեռացնի իր հաջորդ տարրը, և ապա այդ տարրերը միավորում է մեկում։

Маամուլ:

• zip սինխրոնիզացնում է հոսքերը տարրերով, այսինքն՝ սպասում է, որ բոլոր աղբյուրները նույն դիրքում տարր տրամադրեն։
• Հոսքերը կարող են կատարվել հերթական կամ պարալել՝ կախված ծրագրավորողից (Scheduler), բայց zip ինքնուրույն չի սկսում դրանք պարալել։

Եթե անհրաժեշտ է պարալել կատարմամբ, ապա պետք է հստակ օգտագործել համապատասխան օպերատորներ և ծրագրավորողներ, օրինակ՝ subscribeOn(Schedulers.io())։

Օրինակ՝

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

Այստեղ հոսքերը կարող են կատարվել պարալել շնորհիվ subscribeOn, բայց zip կսպասի, մինչև երկուսը էլեմենտները արտանետեն, որպեսզի դրանք միավորի։