रेट्रोफिट डिफ़ॉल्ट धागा

Question

अपने Android एप्लिकेशन में RxJava साथ Retrofit उपयोग करते हैं, और मेरे कोड:

public void getConfig(NetworkSubscriber subscriber) { 
    Observable<Config> observable = mApi.getConfig(); 
    observable.subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(subscriber); 
} 

public void getCode(String mobile, int type, NetworkSubscriber subscriber) { 
    Observable<BaseMessageEntity> observable = mApi.getCode(mobile, type); 
    observable.subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(subscriber); 
} 

और मुझे .subscribeOn(Schedulers.newThread()) लिखने के लिए नहीं करना चाहते हैं और .observeOn(AndroidSchedulers.mainThread()) हर व्यवसाय विधि

मैं कैसे कर सकते हैं ?

Answer 1

यदि आप प्रत्येक कॉल पर इच्छित थ्रेड निर्दिष्ट नहीं करना चाहते हैं, तो आप अपने थ्रेड को डिफ़ॉल्ट रूप से सेट करने के लिए RxJavaCallAdapterFactory के आसपास एक रैपर बना सकते हैं।

public class RxThreadCallAdapter extends CallAdapter.Factory { 

    RxJavaCallAdapterFactory rxFactory = RxJavaCallAdapterFactory.create(); 
    private Scheduler subscribeScheduler; 
    private Scheduler observerScheduler; 

    public RxThreadCallAdapter(Scheduler subscribeScheduler, Scheduler observerScheduler) { 
     this.subscribeScheduler = subscribeScheduler; 
     this.observerScheduler = observerScheduler; 
    } 

    @Override 
    public CallAdapter<?> get(Type returnType, Annotation[] annotations, Retrofit retrofit) { 
     CallAdapter<Observable<?>> callAdapter = (CallAdapter<Observable<?>>) rxFactory.get(returnType, annotations, retrofit); 
     return callAdapter != null ? new ThreadCallAdapter(callAdapter) : null; 
    } 

    final class ThreadCallAdapter implements CallAdapter<Observable<?>> { 
     CallAdapter<Observable<?>> delegateAdapter; 

     ThreadCallAdapter(CallAdapter<Observable<?>> delegateAdapter) { 
      this.delegateAdapter = delegateAdapter; 
     } 

     @Override public Type responseType() { 
      return delegateAdapter.responseType(); 
     } 

     @Override 
     public <T> Observable<?> adapt(Call<T> call) { 
      return delegateAdapter.adapt(call).subscribeOn(subscribeScheduler) 
       .observeOn(observerScheduler); 
     } 
    } 
} 

और फिर अपने निर्माता के अंतर्गत RxJavaCallAdapterFactory.create() के बजाय इसका इस्तेमाल -

Retrofit retrofit = new Retrofit.Builder() 
    .baseUrl("https://api.github.com/") 
    .addConverterFactory(GsonConverterFactory.create()) 
    .addCallAdapterFactory(new RxThreadCallAdapter(Schedulers.io(), AndroidSchedulers.mainThread())) 
    .build(); 

Answer 2

आप इसे compose() का उपयोग करके एक पंक्ति में कम कर सकते हैं। उदाहरण के लिए, नीचे आपके getConfig() विधि का एक संशोधित संस्करण है। यह मानता है कि आप रेट्रोलंबडा का उपयोग कर रहे हैं।

public void getConfig(NetworkSubscriber subscriber) { 
    Observable<Config> observable = mApi.getConfig(); 
    observable 
      .compose(this::setupThreads) 
      .subscribe(subscriber); 
} 

setupThreads() विधि इस प्रकार दिखाई देगा:

private <T> Observable<T> setupThreads(final Observable<T> observable) { 
    return observable 
      .subscribeOn(Schedulers.newThread()) 
      .observeOn(AndroidSchedulers.mainThread()); 
} 

कुछ संदर्भ:

• RxJava विकी - Transformational Operators
• दान ल्यू ब्लॉग पोस्ट - Don't break the chain: use RxJava's compose() operator

Answer 3

subscribeOn के लिए एक डिफ़ॉल्ट अनुसूचक है करने के लिए आप जब अपने Retrofit उदाहरण बनाकर सीधे RxJavaCallAdapterFactory लिए एक तर्क के रूप में यह पारित कर सकते हैं:

new Retrofit.Builder() 
      .client(okHttpClient) 
      .addCallAdapterFactory(RxJavaCallAdapterFactory.createWithScheduler(Schedulers.io())) 
      .build(); 

रेट्रोफिट में पेश किया गया 2.0.0