Kokie mechanizmai naudojami RxJava norint valdyti vykdymo srautų perjungimą?

RxJava operatoriai subscribeOn() ir observeOn() naudojami vykdymo srautų valdymui.

• subscribeOn() nustato, kuriame sraute įvyks prenumerata ir pradinio Observable vykdymas. Paprastai naudojama nurodyti foninį srautą, pvz., Schedulers.io() įvesties/išvesties operacijoms.

• observeOn() perjungia srautą, kuriame bus apdorojami tolesni operatoriai ir galutiniai prenumeratoriai. Pavyzdžiui, galima perjungti į Android pagrindinį srautą naudojant AndroidSchedulers.mainThread().

Pavyzdys:

Observable.just("data")
    .subscribeOn(Schedulers.io())          // vykdymas foniniame sraute
    .observeOn(AndroidSchedulers.mainThread()) // rezultatų apdorojimas UI sraute
    .subscribe(data -> {
        // UI atnaujinimas
    });

Taip subscribeOn nustato duomenų šaltinio srautą, o observeOn — rezultatų apdorojimo srautą.