Observable<T>.subscribeOn

Observable<T>.subscribeOnで、Observable<T>.createに渡した発行処理スレッドのスケジューラをセットできる。

Observable (RxJava Javadoc 1.3.8)

キャッシュされたスレッド(I/O以外)で実行する場合は、Schedulers.computation()をセット。

[1]:id = 1, name = main
[3]:id = 1, name = main
[2]:id = 14, name = RxComputationScheduler-1
[4]:id = 14, name = RxComputationScheduler-1
[5]:id = 1, name = main
1
[4]:id = 14, name = RxComputationScheduler-1
2
[4]:id = 14, name = RxComputationScheduler-1
3
Completed!

発行処理も、通知処理も、RxComputationScheduler-1というスレッドで実行している。

Sample/rxjava/Observable_T/subscribeOn/src/Observable_T at master · bg1bgst333/Sample · GitHub