Кадом механизмҳо дар RxJava барои идора кардани гузаришҳои ҷараёнҳои иҷро истифода мешаванд?

Дар RxJava, операторҳои subscribeOn() ва observeOn() барои идора кардани сӯрохиҳои иҷро истифода мешаванд.

• subscribeOn() муайян мекунад, ки дар кадом сӯрохи иҷрои обуна ва иҷрои Observable асосӣ хоҳад буд. Одатан барои нишон додани сӯрохи пасзамина истифода мешавад, масалан, Schedulers.io() барои амалиётҳои воридотӣ-баромадӣ.

• observeOn() сӯрохиро, ки дар он операторҳо ва обунаҳои охирин коркард мешаванд, мегузаронад. Масалан, бо истифода аз AndroidSchedulers.mainThread() метавон ба сӯрохи асосии Android гузашт.

Масал:

Observable.just("data")
    .subscribeOn(Schedulers.io())          // иҷро дар сӯрохи пасзамина
    .observeOn(AndroidSchedulers.mainThread()) // коркард дар сӯрохи UI
    .subscribe(data -> {
        // навсозии UI
    });

Бинобар ин, subscribeOn сӯрохи барои манбаи маълумотро муайян мекунад, ва observeOn — барои коркарди натиҷаҳо.