RxJavaда ишке ашуу агымдарын которуу үчүн кайсы механизмдер колдонулат?

RxJavaда, subscribeOn() жана observeOn() операторлору аткаруу агымдарын башкаруу үчүн колдонулат.

• subscribeOn() кайсы агымда жазылуу жана оригиналдуу Observable аткарылат экенин аныктайт. Ал көбүнчө артка чегерүү агымын көрсөтүү үчүн колдонулат, мисалы, Schedulers.io() кирүү-чыгуу операциялары үчүн.

• observeOn() кийинки операторлор жана акыркы жазылуучулар иштелип чыккан агымды алмаштырат. Мисалы, Android негизги агымына өтүү үчүн AndroidSchedulers.mainThread() колдонсо болот.

Мисал:

Observable.just("data")
    .subscribeOn(Schedulers.io())          // артка чегерүү агымында иштөө
    .observeOn(AndroidSchedulers.mainThread()) // UI агымында натыйжаны иштетүү
    .subscribe(data -> {
        // UI жаңыртуу
    });

Ошентип, subscribeOn маалымат булагы үчүн агымды белгилейт, ал эми observeOn натыйжаларды иштетүү үчүн агымды белгилейт.