RxJava-da icra axınlarının dəyişdirilməsini idarə etmək üçün hansı mexanizmlər istifadə olunur?

RxJava-da, subscribeOn() və observeOn() operatorları icra axınlarını idarə etmək üçün istifadə olunur.

• subscribeOn() hansı axında abunə olma və ilkin Observable-ın icrasını müəyyən edir. Adətən, arxa plan axını göstərmək üçün istifadə olunur, məsələn, Schedulers.io() giriş-çıxış əməliyyatları üçün.

• observeOn() növbəti operatorların və son abunəçilərin işlənəcəyi axını dəyişir. Məsələn, Android-un əsas axınına keçmək üçün AndroidSchedulers.mainThread() istifadə oluna bilər.

Nümunə:

Observable.just("data")
    .subscribeOn(Schedulers.io())          // arxa plan axınında icra
    .observeOn(AndroidSchedulers.mainThread()) // UI axınında nəticənin işlənməsi
    .subscribe(data -> {
        // UI-ni yeniləyin
    });

Beləliklə, subscribeOn məlumat mənbəyi üçün axını təyin edir, observeOn isə nəticələrin işlənməsi üçün axını təyin edir.