0
RxJava observableに、現在のスケジューラを以前のスケジューラに変更するよう依頼する方法はありますか?RxJavaが以前のスケジューラに戻る
Observable
.just(null)
作業が
.subscribeOn(Schedulers.io())
作業は、計算スケジューラに移動され、IOスケジューラに移動され
.flatMap(__ -> Observable.timer(30, TimeUnit.MILLISECONDS))
だから、ここで私は明示的に観察するために依頼する必要はありません以前のスケジューラ(これはio)に戻ります。
.subscribe(__ -> System.out.println(Thread.currentThread().getName()));
rxjava:1.1.8
「subscribeOn」は、オペレータがそのスケジューラでObstevable Upsteamを購読することを意味します。 AFAIKには、上級職にしか影響を及ぼさない方法があります。あるいはObservableに 'subscribeOn'と' observeOn'の組み合わせを使うこともできます。 –