Az RxJava zip operátorának használata biztosítja az adatfolyamok egyidejű végrehajtását?

Az RxJava zip operátora nem garantálja az adatfolyamok egyidejű (párhuzamos) végrehajtását. Több Observable elemeit kombinálja, várva, hogy mindegyik kibocsátja a következő elemet, majd ezeket az elemeket egyesíti.

Fontos:

• A zip szinkronizálja az adatfolyamokat elemenként, azaz várja, hogy minden forrás ugyanazon a pozíciónál egy elemet szolgáltasson.
• Az adatfolyamok szekvenciálisan vagy párhuzamosan futtathatók a scheduler (ütemező) függvényében, de a zip önmagában nem indítja el őket párhuzamosan.

Ha párhuzamos végrehajtásra van szükség, akkor kifejezetten használni kell a megfelelő operátorokat és ütemezőket, például a subscribeOn(Schedulers.io())-t.

Példa:

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

Itt az adatfolyamok párhuzamosan futtathatók a subscribeOn segítségével, de a zip meg fogja várni, hogy mindkettő kibocsátson egy elemet, mielőtt összefűzi azokat.