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