RxJava即時のようなスケジューラ

Question

Activity.runOnUiThread()はこれを持っている：

if (Thread.currentThread() != mUiThread) { 
    mHandler.post(action); 
} else { 
    action.run(); 
} 

それは意味し、それは私はないです場合ハンドラにUIスレッドと投稿アクションにいる場合は、直ちにアクションを実行します。 私はこの機能のようなRxJava Schedulerを探しています。それは存在しますか？

Answer 1

はい簡​​単です。

getSomeObservable().observeOn(AndroidSchedulers.mainThread()) 

後.observeOn（AndroidSchedulers.mainThread（））あなたは、観察を購読することができますし、コールバックは、メインスレッドに来ます。

.subscribe(new Subscriber<Object>() { 
       @Override 
       public void onCompleted() { 
        Log.i(TAG,Thread.currentThread().getName()); 
       } 

       @Override 
       public void onError(Throwable e) { 
        Log.i(TAG,Thread.currentThread().getName()); 
       } 

       @Override 
       public void onNext(Object o) { 
        Log.i(TAG,Thread.currentThread().getName()); 
       } 
      });