RxJava2 + Retrofit 2. हम एंड्रॉइड पर इंटरनेट की स्थिति की कमी को संभालने के लिए एडाप्टर को संशोधित करते हैं

काफी बार नेटवर्क के लिए बार-बार अनुरोध करना आवश्यक है, उदाहरण के लिए, जब उपयोगकर्ता के पास इंटरनेट नहीं था और वह इंटरनेट से डेटा प्राप्त करना चाहता था। यह प्रकट होने पर अनुरोध को फिर से फेंकना अच्छा होगा। उपयोगकर्ता को एक विशिष्ट यूआई दिखाने के लिए यह अच्छा अभ्यास है जो उसे समझाएगा कि क्या हुआ और अनुरोध को फिर से फेंकने की अनुमति देगा। इस तरह के तर्क जोड़ना काफी दर्दनाक हो सकता है, खासकर जब हमारे पास बड़ी संख्या में ViewModel कक्षाएं होती हैं। बेशक, आप प्रत्येक ViewModel वर्ग में पुनः क्वेरी तर्क को लागू कर सकते हैं, लेकिन यह सुविधाजनक नहीं है और त्रुटियों की एक बड़ी संभावना है।

क्या इस प्रसंस्करण को केवल एक बार करने का कोई तरीका है?

सौभाग्य से, RxJava2 और Retrofit2 इसे अनुमति देते हैं।

Stackoverflow पर पहले से ही कई समाधान हैं:

1. अपना खुद का CallAdapterFactory बनाना (अधिक जानकारी यहाँ )
2. प्रकाशित करें श्रृंखला का उपयोग करके प्रकाशित करेंसबजेक्ट (अधिक जानकारी यहां )

पहला समाधान RxJava1 का उपयोग करता है, यह पहले से ही पुराना है और यह भी घटना की घटना पर प्रतिक्रिया किए बिना, कई बार श्रृंखला को दोहराता है। दूसरा समाधान अच्छा है, लेकिन हमें प्रत्येक श्रृंखला में रिट्रीवर ऑपरेटर का उपयोग करने की आवश्यकता है। और इसलिए, मैंने दो समाधानों को एक में जोड़ दिया।

कार्यान्वयन

चलो एक सरल परियोजना बनाते हैं। मुख्य स्क्रीन पर दो टैब रखें। उनमें से प्रत्येक पाठ प्रदर्शित करता है जो दिखाएगा कि कितने तत्व एपीआई द्वारा लोड किए गए हैं। यदि निष्पादन के दौरान कोई त्रुटि होती है, तो हम एक SnackBar को Try Again बटन के साथ प्रदर्शित करते हैं।



हम ऐसे बेस क्लास को बेसएक्टिविटी, बेसग्रैगमेंट, बेस व्यूमॉडल के रूप में परिभाषित करते हैं, वे एक स्थान पर अनुरोध पुनरावृत्ति के तर्क को लागू करने और इस कोड के दोहराव से बचने के लिए आवश्यक हैं। BaseFragment का विस्तार करने वाले दो टुकड़े बनाएँ। प्रत्येक रखे हुए टुकड़े का अपना ViewModel है और स्वतंत्र रूप से एपीआई के लिए अनुरोध करता है। मैंने इन स्निपेट को यह दिखाने के लिए बनाया कि यदि कोई त्रुटि होती है, तो प्रत्येक अनुरोध दोहराया जाएगा। इसके बाद, एक RxRetryCallAdapterFactory फैक्ट्री बनाएं जो CallAdapter.Factory का विस्तार करता है। उसके बाद, RxJava2CallAdapterFactory का एक उदाहरण बनाएं। हमें RxJava2CallAdapter को एक्सेस करने के लिए इस उदाहरण की आवश्यकता है, क्योंकि हम उस कोड को डुप्लिकेट नहीं करना चाहते हैं जो पहले से ही रेट्रोफिट लाइब्रेरी में है। इसके अलावा, आइए एक स्थिर विधि बनाएं जो हमारे कारखाने का एक उदाहरण देगा। नीचे नमूना कोड:

class RxRetryCallAdapterFactory : CallAdapter.Factory() { companion object { fun create() : CallAdapter.Factory = RxRetryCallAdapterFactory() } private val originalFactory = RxJava2CallAdapterFactory.create() override fun get(returnType : Type, annotations : Array<Annotation>, retrofit : Retrofit) : CallAdapter<*, *>? { val adapter = originalFactory.get(returnType, annotations, retrofit) ?: return null return RxRetryCallAdapter(adapter) } } 

इसके बाद, एक RxRetryCallAdapter बनाएं जो CallAdapter इंटरफ़ेस को लागू करता है और हमें कॉल एडॉप्टर उदाहरण को कंस्ट्रक्टर के पास करना होगा। वास्तव में, यह RxJava2CallAdapter का एक उदाहरण होना चाहिए, जो मूल कारखाना लौटाता है।

अगला, हमें निम्नलिखित चीजों को लागू करने की आवश्यकता है:

• पुनरावृत्ति कार्यक्षमता को लागू करने के लिए रिट्रीवेन स्टेटमेंट का उपयोग किया जाता है
• doOnError () स्टेटमेंट जो त्रुटियों को हैंडल करता है। इसका उपयोग प्रसारण को भेजने के लिए किया जाता है, जो कि बेसएक्टिविटी में संसाधित होता है और उपयोगकर्ता को स्नैकबार दिखाता है।
• पब्लिशसबजेक्ट का इस्तेमाल एक इवेंट ट्रिगर के रूप में किया जाता है जो चेन पर फिर से हस्ताक्षर करता है।
• अवलोकन करें (Schedulers.io ()) ऑपरेटर जिसे पब्लिशसबजेक्ट पर लागू किया जाना चाहिए (यदि यह लाइन नहीं जोड़ी गई है, तो सदस्यता मुख्य थ्रेड में होगी और हमें NetworkOnMainThreadException मिल जाएगी
• हम PublishSubject को Flowable में बदलते हैं और BackpressureStrategy.LATEST सेट करते हैं, क्योंकि हमें केवल अंतिम त्रुटि की आवश्यकता होती है

नोट: PublishSubject प्रदान करने के लिए, मैंने एक साधारण सिंगलटन क्लास बनाया, जो प्रोजेक्ट के सभी सिंगलटन निर्भरता को उजागर करता है। एक वास्तविक परियोजना में, आप डैगर 2 जैसी निर्भरता इंजेक्शन ढांचे का उपयोग करने की संभावना रखते हैं

 class RxRetryCallAdapter<R>(private val originalAdapter : CallAdapter<R, *>) : CallAdapter<R, Any> { override fun adapt(call : Call<R>) : Any { val adaptedValue = originalAdapter.adapt(call) return when (adaptedValue) { is Completable -> { adaptedValue.doOnError(this::sendBroadcast) .retryWhen { AppProvider.provideRetrySubject().toFlowable(BackpressureStrategy.LATEST) .observeOn(Schedulers.io()) } } is Single<*> -> { adaptedValue.doOnError(this::sendBroadcast) .retryWhen { AppProvider.provideRetrySubject().toFlowable(BackpressureStrategy.LATEST) .observeOn(Schedulers.io()) } } //same for Maybe, Observable, Flowable else -> { adaptedValue } } } override fun responseType() : Type = originalAdapter.responseType() private fun sendBroadcast(throwable : Throwable) { Timber.e(throwable) LocalBroadcastManager.getInstance(AppProvider.appInstance).sendBroadcast(Intent(BaseActivity.ERROR_ACTION)) } } 

जब उपयोगकर्ता पुनः प्रयास करें बटन पर क्लिक करता है, हम onNext PublishSubject पर कॉल करते हैं। उसके बाद, हम आरएक्स चेन की फिर से सदस्यता लेते हैं।

परीक्षण

इंटरनेट बंद करें और एप्लिकेशन चलाएं। प्रत्येक टैब पर लोड की गई वस्तुओं की संख्या शून्य है और स्नैकबार एक त्रुटि प्रदर्शित करता है। इंटरनेट चालू करें और कोशिश करें पर क्लिक करें। कुछ सेकंड के बाद, प्रत्येक टैब पर लोड की गई वस्तुओं की संख्या बदल जाती है।



अगर किसी को इसकी आवश्यकता है, तो स्रोत कोड यहां है