Zajišťuje použití operátoru zip v RxJava současné provádění datových toků?

Operátor zip v RxJava nezaručuje současné (paralelní) provádění datových toků. Kombinuje prvky z několika Observable, čeká, až každý z nich vydá svůj další prvek, a poté tyto prvky sloučí do jednoho.

Důležité:

• zip synchronizuje toky podle prvků, tj. čeká, až všechny zdroje poskytnou prvek na stejné pozici.
• Toky mohou být spuštěny sekvenčně nebo paralelně v závislosti na plánovači (Scheduler), ale zip je sám o sobě nespouští paralelně.

Pokud je potřeba paralelní provádění, je nutné výslovně použít příslušné operátory a plánovače, například subscribeOn(Schedulers.io()).

Pří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);

Zde mohou být toky spuštěny paralelně díky subscribeOn, ale zip bude čekat, až oba emitují své prvky, aby je spojil.