https://seoft.tistory.com/26

rx subscribeOn observeOn 요약.kt

package kr.co.seoft.std_of_android_with_kt_mvvm_aac_mock.ui.third

import androidx.lifecycle.MutableLiveData
import io.reactivex.Observable
import io.reactivex.android.schedulers.AndroidSchedulers
import io.reactivex.schedulers.Schedulers
import kr.co.seoft.std_of_android_with_kt_mvvm_aac_mock.data.AppDatabase
import kr.co.seoft.std_of_android_with_kt_mvvm_aac_mock.data.model.User
import kr.co.seoft.std_of_android_with_kt_mvvm_aac_mock.ui.VMHelper
import kr.co.seoft.std_of_android_with_kt_mvvm_aac_mock.util.e

class ThirdVM(private val db: AppDatabase) : VMHelper() {

    val TAG = "ThirdVM"

    val mldSetResult = MutableLiveData<String>()

    fun insertUser(user: User) {

        "START ${Thread.currentThread().name}".e()
        addDisposable(
            Observable.just("")
                .subscribeOn(Schedulers.computation())
                .map {
                    "map1 ${Thread.currentThread().name}".e()
                }
                .observeOn(Schedulers.io())
                .map {
                    "map2 ${Thread.currentThread().name}".e()
                }
                .doOnNext {
                    "doOnNext1 ${Thread.currentThread().name}".e()
                }
                .observeOn(AndroidSchedulers.mainThread())
                .doOnNext {
                    "doOnNext2 ${Thread.currentThread().name}".e()
                }
                .subscribe({
                    mldSetResult.value = "done"
                    "done ${Thread.currentThread().name}".e()
                }, {
                    it.printStackTrace()
                })
        )
    }
}