जावा आरएक्स में कॉलिंग थ्रेड पर कैसे निरीक्षण करें?

Question

वहाँ वैसे भी observeOn समारोह में मौजूदा धागा उपयोग करने के लिए जावा rx बताने के लिए है? मैं एंड्रॉइड सिंकैडाप्टर के लिए कोड लिख रहा हूं और मैं चाहता हूं कि सिंक एडाप्टर थ्रेड में परिणाम मुख्य थ्रेड में न हों। मैं

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

जो उसी तरह एंड्रॉयड rx मुख्य थ्रेड के लिए अनुसूचक बनाता है का उपयोग कर का उपयोग कर की कोशिश की

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

} 

:

रेट्रोफिट + RX जावा के साथ एक उदाहरण नेटवर्क कॉल कि तरह दिखता है लेकिन अब जैसे ही मैं Looper.getMainLooper() के लिए स्थानापन्न के रूप में Looper.myLooper() काम नहीं करता।

मैं शेड्यूलर्स.न्यू थ्रेड() का उपयोग कर सकता हूं लेकिन बहुत से सर्वर कॉल के साथ इसके जटिल सिंकिंग कोड के रूप में मैं लगातार नए नेटवर्क कॉल को आग लगाने के लिए एक नया थ्रेड बनाउंगा जो फिर से अधिक नेटवर्क कॉल लॉन्च करने के लिए नए थ्रेड बनायेगा । क्या इसे करने का कोई तरीका है? या मेरा दृष्टिकोण पूरी तरह से गलत है?

Answer 1

ओह, मैं सिर्फ इस विकि में में पाया: 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(); 

मुझे लगता है कि यह भी अपने मामले के लिए काम करना चाहिए - एक नया थ्रेड के निर्माण को छोड़कर, बिल्कुल ... तो बस:

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

Schedulers.immediate()

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

} 

इसका वर्णन का उपयोग कर प्रयास का कहना है: Creates and returns a Scheduler that executes work immediately on the current thread.

नोट:
मुझे लगता है कि क्योंकि यह पहले से ही एक अलग धागा