RxJava'da ijro oqimlarini almashtirishni boshqarish uchun qanday mexanizmlar ishlatiladi?

RxJava'da, subscribeOn() va observeOn() operatorlari bajarilish oqimlarini boshqarish uchun ishlatiladi.

• subscribeOn() qaysi oqimda obuna bo'lish va asl Observable bajarilishini belgilaydi. Odatda, fon oqimini ko'rsatish uchun ishlatiladi, masalan, Schedulers.io() kirish-chiqish operatsiyalari uchun.

• observeOn() keyingi operatorlar va yakuniy obunachilarni ishlash uchun oqimni o'zgartiradi. Masalan, Androidning asosiy oqimiga o'tish uchun AndroidSchedulers.mainThread() dan foydalanish mumkin.

Misol:

Observable.just("data")
    .subscribeOn(Schedulers.io())          // fon oqimida bajarish
    .observeOn(AndroidSchedulers.mainThread()) // UI oqimida natijani ishlash
    .subscribe(data -> {
        // UI-ni yangilash
    });

Shunday qilib, subscribeOn ma'lumot manbasi uchun oqimni belgilaydi, observeOn esa natijalarni ishlash uchun oqimni belgilaydi.