RxJava-da zip operatorunun istifadəsi məlumat axınlarının eyni vaxtda icra olunmasını təmin edir?

RxJava-da zip operatoru məlumat axınlarının eyni vaxtda (paralel) icra olunmasını təmin etmir. O, bir neçə Observable-dən elementləri birləşdirir, hər biri növbəti elementini çıxaranda gözləyir və sonra bu elementləri birləşdirir.

Vacib:

• zip axınları elementlər üzrə sinxronlaşdırır, yəni bütün mənbələr eyni mövqedə element təqdim etdikdə gözləyir.
• Axınlar ardıcıl və ya paralel şəkildə işlədilə bilər, planlayıcı (Scheduler) asılı olaraq, amma zip onları öz-özünə paralel başlatmır.

Əgər paralel icra tələb olunursa, uyğun operatorlar və planlayıcılar açıq şəkildə istifadə olunmalıdır, məsələn, subscribeOn(Schedulers.io()).

Nümunə:

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

Burada axınlar subscribeOn sayəsində paralel işləyə bilər, amma zip hər iki element çıxana qədər gözləyir və onları birləşdirir.