RxJava Immediate-wie Scheduler

Question

Activity.runOnUiThread() hat dies:

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

Es bedeutet, es läuft Aktion sofort, wenn ich in UI-Thread und Beiträge Aktion bin Handler, wenn ich nicht bin. Ich suche RxJava Scheduler wie diese Funktionalität. Gibt es es?

Answer 1

Ja, es ist einfach.

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

nach .observeOn (AndroidSchedulers.mainThread()) Sie Ihre beobachtbare abonnieren und Rückrufe werden in Hauptthread kommen.

.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()); 
       } 
      });