Wie beobachte ich den aufrufenden Thread in Java Rx?

Question

ist es sowieso zu sagen java rx den aktuellen thread in der observeOn funktion zu verwenden? Ich schreibe Code für den Android-Syncadapter und ich möchte, dass die Ergebnisse im Sync-Adapter-Thread und nicht im Haupt-Thread beobachtet werden.

Ein Beispiel Netzanruf mit Retrofit + RX Java sieht ungefähr wie folgt aus:

MyRetrofitApi.getInstance().getObjects() 
.subscribeOn(Schedulers.io()) 
.observeOn(<current_thread>) 
.subscribe(new Subscriber<Object>() { 
    //do stuff on the sync adapter thread 

} 

ich versucht, mit

... 
.observeOn(AndroidSchedulers.handlerThread(new Handler(Looper.myLooper()))) 
... 

verwendet, die die gleiche Art und Weise android rx den Scheduler für den Haupt-Thread erstellt ist funktioniert aber nicht mehr, sobald ich Looper.myLooper() für Looper.getMainLooper() ersetze.

Ich könnte die Schedulers.newThread() aber als komplexe Synchronisierung Code mit einer Menge von Serveranrufe würde ich ständig einen neuen Thread erstellen, nur um neue Netzwerkanrufe zu feuern, die wiederum neue Threads erstellen, um mehr Netzwerkanrufe zu starten . Gibt es eine Möglichkeit, dies zu tun? Oder ist mein Ansatz völlig falsch?

Answer 1

Oh, ich habe gerade diese im Wiki unter: https://github.com/ReactiveX/RxAndroid#observing-on-arbitrary-threads

new Thread(new Runnable() { 
    @Override 
    public void run() { 
     final Handler handler = new Handler(); // bound to this thread 
     Observable.just("one", "two", "three", "four", "five") 
       .subscribeOn(Schedulers.newThread()) 
       .observeOn(HandlerScheduler.from(handler)) 
       .subscribe(/* an Observer */) 

     // perform work, ... 
    } 
}, "custom-thread-1").start(); 

ich denke, das sollte für Ihren Fall arbeiten, auch - mit Ausnahme der Schaffung eines neuen Thema, natürlich ... Also einfach:

final Handler handler = new Handler(); // bound to this thread 
MyRetrofitApi.getInstance().getObjects() 
    .subscribeOn(Schedulers.io()) 
    .observeOn(HandlerScheduler.from(handler)) 
    .subscribe(new Subscriber<Object>() { 
     //do stuff on the sync adapter thread 

    } 

Answer 2

Versuchen Sie es mit Schedulers.immediate()

MyRetrofitApi.getInstance().getObjects() 
.subscribeOn(Schedulers.io()) 
.observeOn(Schedulers.immediate()) 
.subscribe(new Subscriber<Object>() { 
    //do stuff on the sync adapter thread 

} 

Die Beschreibung sagt: Creates and returns a Scheduler that executes work immediately on the current thread.

HINWEIS:
Ich denke, es ist okay, auf dem Gewinde des SyncAdapter der ganze Arbeit zu halten, weil es bereits einen anderen Thread mit