Czy użycie operatora zip w RxJava zapewnia jednoczesne wykonywanie strumieni danych?

Operator zip w RxJava nie zapewnia równoczesnego (równoległego) wykonywania strumieni danych. Łączy elementy z kilku Observable, oczekując, aż każdy z nich wyemituje swój następny element, a następnie łączy te elementy w jeden.

Ważne:

• zip synchronizuje strumienie po elementach, czyli czeka, aż wszystkie źródła dostarczą element na tej samej pozycji.
• Strumienie mogą być wykonywane sekwencyjnie lub równolegle w zależności od planisty (Scheduler), ale zip sam z siebie nie uruchamia ich równolegle.

Jeśli potrzebne jest równoległe wykonanie, należy wyraźnie użyć odpowiednich operatorów i planistów, np. subscribeOn(Schedulers.io()).

Przykład:

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

Tutaj strumienie mogą być wykonywane równolegle dzięki subscribeOn, ale zip będzie czekał, aż oba wyemitują swoje elementy, aby je połączyć.