2017-06-16 6 views
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

+0

「subscribeOn」は、オペレータがそのスケジューラでObstevable Upsteamを購読することを意味します。 AFAIKには、上級職にしか影響を及ぼさない方法があります。あるいはObservableに 'subscribeOn'と' observeOn'の組み合わせを使うこともできます。 –

答えて

0

あなたはまったくスレッドまたは同じスケジューラに戻りたいですか?前者は1.xで利用できませんが、2.xではextensions libraryで可能です。後者は、observeOn(Schedulers.io())の使用を必要とします。

関連する問題