Operator subscribeOn memiliki definisi yang sederhana tapi memiliki perilaku yang kadang tidak disadari pengguna. Sebagai contoh, lihat snippet di bawah:
Observable.create {
Thread(Runnable {
it.onNext(1)
it.onComplete()
}, "Thread A").start()
}
.subscribeOn(Schedulers.newThread())
.subscribe {
println("Subscriber on ${Thread.currentThread()}")
}
Di thread apakah subscriber berada?
a. new thread,
