Come osservare il thread chiamante in java rx?

Question

c'è comunque da dire a java rx di usare il thread corrente nella funzione observOn? Sto scrivendo il codice per Android Syncadapter e voglio che i risultati vengano osservati nel thread dell'adattatore di sincronizzazione e non nel thread principale.

Una chiamata rete di esempio con Retrofit + RX Java sembra qualcosa di simile:

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

} 

Ho provato ad utilizzare utilizzando

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

che è allo stesso modo rx Android crea lo scheduler per il thread principale ma non funziona più appena sostituisco Looper.myLooper() per Looper.getMainLooper().

Potrei usare Schedulers.newThread() ma come il suo complesso codice di sincronizzazione con molte chiamate al server creerò costantemente un nuovo thread solo per sparare nuove chiamate di rete che creano nuovamente nuovi thread per avviare più chiamate di rete . C'è un modo per fare questo? O il mio approccio è completamente sbagliato?

Answer 1

Oh, ho appena trovato questo nel wiki all'indirizzo: 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(); 

Penso che questo dovrebbe funzionare per il vostro caso, troppo - tranne la creazione di un nuovo thread, naturalmente ... Quindi, solo:

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

provare a utilizzare Schedulers.immediate()

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

} 

La sua descrizione dice: Creates and returns a Scheduler that executes work immediately on the current thread.

NOTA:
penso che sia bene per mantenere tutto il lavoro sul filo del SyncAdapter perché sta già utilizzando un thread diverso