RxJava Thread Switching like a Pro - Medium Article - 2

simple-demonstration.kt

/*
 * RxJava simple demonstration of subscribeOn() and observeOn()
 */

println("Calling function : Thread = ${Thread.currentThread().id}")

Observable
    .just(1)
    .doOnNext {
        println("OnNext : Val = $it : Thread = ${Thread.currentThread().id}")
    }
    .map {
        println("Map : Val = $it : Thread = ${Thread.currentThread().id}")
        2
    }
    .subscribeOn(Schedulers.newThread())
    .observeOn(Schedulers.newThread())
    .subscribe(
        {
            // onNext
            println("OnNext : Val = $it : Thread = ${Thread.currentThread().id}")
        },
        {
            // onError
        },
        {
            // onComplete
            println("OnComplete : Thread = ${Thread.currentThread().id}")
        }
    )

/*
 * End
 */