Rx घटना स्रोत संदर्भ

RxJava का उपयोग बड़ी संख्या में एंड्रॉइड अनुप्रयोगों में किया जाता है, लेकिन एक ही समय में कई अन्य घटनाओं के अन्य स्रोतों को नहीं जानते हैं, सिवाय ऑब्जर्वेबल और शायद फ़्लोएबल के। वे विशेष वर्ग एकल, हो सकता है, और पूर्णता के बारे में भूल जाते हैं, जो अक्सर कोड में अधिक स्पष्टता जोड़ने में सक्षम होते हैं।

बिल्ली के नीचे आपको RxJava में मौजूद घटनाओं के स्रोतों पर एक चीट शीट मिलेगी।

कंप्लीटेबल वास्तव में रननेबल का एक आरएक्स एनालॉग है। यह एक ऑपरेशन है जिसे किया जा सकता है या नहीं। यदि हम कोटलिन के साथ एक सादृश्य आकर्षित करते हैं, तो यह आरएक्स की दुनिया से मजेदार (पूर्ण) है। तदनुसार, इसे सब्सक्राइब करने के लिए, आपको ऑन-प्रिमाइसेस और ऑनर्र को लागू करने की आवश्यकता है। इसे मान (ऑब्जर्वेबल # जस्ट, ...) से नहीं बनाया जा सकता क्योंकि इसे इसके लिए नहीं बनाया गया है।

एकल - प्रतिक्रियाशील कॉलेबल, क्योंकि यहां ऑपरेशन के परिणाम को वापस करना संभव है। कोटलिन के साथ तुलना जारी रखते हुए, हम कह सकते हैं कि सिंगल फन सिंगल (): टी {} है। इस प्रकार, इसकी सदस्यता के लिए, आपको onSuccess (T) और onError को लागू करना होगा।

हो सकता है - एकल और पूर्ण के बीच एक क्रॉस, क्योंकि यह एक मूल्य, कोई मूल्य और त्रुटि का समर्थन करता है। विधियों के साथ एक अस्पष्ट समानांतर को खींचना अधिक कठिन है, लेकिन मुझे लगता है कि शायद मज़ा मजेदार है (): टी? {, जिसका कोई परिणाम नहीं होने पर अशक्त लौट आता है। यह अनुमान लगाना आसान है कि सदस्यता के लिए आपको onSuccess (T), onComplete, और onError को परिभाषित करने की आवश्यकता है।

यह ध्यान रखना महत्वपूर्ण है कि onSuccess (T) और onComplete पारस्परिक रूप से अनन्य हैं। यानी पहली कॉल करने के मामले में, आप दूसरे का इंतजार नहीं कर सकते।

इसकी बहुमुखी प्रतिभा के कारण, ऑब्जर्वेबल सबसे आम स्रोत है। वह जानता है कि घटनाओं का उत्पादन कैसे नहीं किया जा सकता है, और उनमें से कई को उत्पन्न करने के लिए, इसलिए उनका उपयोग हमेशा किया जा सकता है जब अन्य विकल्प उपयुक्त नहीं होते हैं। इसके बावजूद, ऑब्जर्वेबल में एक खामी है - यह नहीं पता है कि बैकपेचर को कैसे संभालना है। इसकी सदस्यता के लिए, आपको onNext (T), onError और onComplete की आवश्यकता है।

बैकप्रेशर - एक ऐसी स्थिति जब नई घटनाएँ बहुत तेजी से आती हैं, जबकि उनके पास प्रक्रिया के लिए समय होता है, और बफर में जमा होना शुरू हो जाता है। इससे OutOfMemoryError जैसी परेशानी हो सकती है। अधिक विवरण यहां पाया जा सकता है ।

ConnectableObservable - ऑब्जर्वेबल का एक गर्म संस्करण। सभी डेटा स्रोत सदस्यता के समय घटनाओं की अपनी धारा जारी करना शुरू करते हैं। लेकिन इस आदमी को नहीं। ऐसा करने के लिए, ConnectableObservable कॉल करने के लिए कनेक्ट होने की प्रतीक्षा करता है। ऐसा इसलिए किया जाता है ताकि कई पर्यवेक्षक प्रत्येक सदस्यता पर पुनः आरंभ किए बिना घटनाओं की एक धारा की समीक्षा कर सकें। वर्णन करने के लिए, मैं आपको निम्नलिखित स्निपेट दूंगा:

val observable = Observable.fromCallable { Log.d("RxLogs", "observable fromCallable executed") Thread.sleep(1000) }.subscribeOn(Schedulers.computation()) observable.subscribe() observable.subscribe() observable.subscribe() observable.subscribe() 

कंसोल में होगा:
अवलोकन योग्य निष्पादन योग्य
अवलोकन योग्य निष्पादन योग्य
अवलोकन योग्य निष्पादन योग्य
अवलोकन योग्य निष्पादन योग्य

 val connectedObservable = Observable.fromCallable { Log.d("RxLogs", "connectedObservable fromCallable executed") Thread.sleep(1000) }.subscribeOn(Schedulers.computation()) .publish() connectedObservable.subscribe() connectedObservable.subscribe() connectedObservable.subscribe() connectedObservable.subscribe() connectedObservable.connect() 

और इस मामले में: अवलोकन योग्य निष्पादन योग्य

फ़्लोएबल - एक स्रोत जो बैकपेचर के प्रसंस्करण के लिए अतिरिक्त ऑपरेटर प्रदान करता है। जब आपको 10,000 से अधिक घटनाओं को संभालने की आवश्यकता होती है जो एक के बाद एक जल्दी से घटित होती हैं, तो इसका पालन करने की सिफारिश की जाती है।

बाद में ConnectableObservable के रूप में एक ही संभावनाओं को खोलने, एक ConnectableFlowable बना सकते हैं।

ईवेंट जनरेटर के बारे में बोलते हुए, कोई भी विषय और प्रोसेसर का उल्लेख नहीं कर सकता है।

विषय - एक ऐसा वर्ग जो एक स्रोत और एक ब्राउज़र दोनों हो सकता है। यह आपको इसका उपयोग करने की अनुमति देता है, उदाहरण के लिए, विभिन्न प्रकार के नियंत्रकों में, जो इसे ऑब्जर्वेबल के रूप में बाहर की ओर देगा और अंदर एक पर्यवेक्षक के रूप में सूचित करेगा। अगला, हम इस वर्ग के विभिन्न कार्यान्वयनों से गुजरेंगे।

AsyncSubject / AsyncProcessor अंतिम ईवेंट को तब तक रखता है जब तक कि थ्रेड सही तरीके से समाप्त नहीं हो जाता है, और फिर इसे ग्राहकों को भेजता है। यदि कोई त्रुटि होती है, तो कोई ईवेंट अग्रेषित नहीं किया जाएगा।



PublishSubject / PublishProcessor आगे आने वाली घटनाओं को टर्मिनल सिग्नल आने तक आगे बढ़ाता है। धारा या त्रुटि के अंत के बाद, यह उचित घटनाओं को लौटाता है।



BehaviorSubject / BehaviorProcessor पब्लिशसब्यूज / पब्लिशप्रोसेसर के समान काम करता है, लेकिन सदस्यता पर यह अंतिम घटना, यदि कोई हो, और यदि Subject ने टर्मिनल स्थिति में संक्रमण नहीं किया है, तो वापस करता है।



ReplaySubject / ReplayProcessor - स्टेरॉयड पर BehaviourSubject / BehaviorProcessor। यह एक अंतिम घटना नहीं है, लेकिन जितना आत्मा की इच्छा है। यदि आप एक पूर्ण ReplaySubject या ReplayProcessor की सदस्यता लेते हैं, तो सभी संचित डेटा प्राप्त होंगे।

इस प्रकार, ReplaySubject.createWithSize (1) और BehaviourSubject.create () टर्मिनल राज्य में संक्रमण के बाद अलग तरीके से काम करते हैं। सदस्यता के दौरान, पहला अंतिम ईवेंट वापस कर देगा, और दूसरा नहीं होगा। यह रिप्लेप्रोसेसर के लिए भी सही है।

TotaltableSubject , MightSubject और SingleSubject , PublishSubject के समान ही काम करते हैं, केवल क्रमशः कम्पोज़िबल, हो सकता है और सिंगल के साथ उपयोग के लिए डिज़ाइन किया गया है।

UnicastSubject / UnicastProcessor वास्तव में एक ReplaySubject है जो यह सुनिश्चित करता है कि इसके केवल एक ग्राहक हैं। पुन: सदस्यता लेने का प्रयास करने पर यह अवैध तरीके से फेंकता है।



यानी अगला स्निपेट

 val subject = UnicastSubject.create<String>(3) repeat(3) { subject.onNext(it.toString()) } subject.onComplete() subject.subscribe({ Log.d("RxLogs", it) }, { }, { Log.d("RxLogs", "complete") }) 

लॉग करने के लिए उत्पादन होगा
0
1
2
पूरा

मल्टीकास्टप्रोसेसर एक छोटी सुविधा के अपवाद के साथ, पब्लिशप्रोसेसर के समान काम करता है। वह जानता है कि आने वाली धारा के लिए बैकस्पेस को कैसे संभालना है। मल्टीकास्टप्रोसेसर आपको बफर के आकार को सेट करने की अनुमति देता है जिस पर वह भविष्य के ग्राहकों के लिए अपस्ट्रीम से तत्वों को पूर्व-क्वेरी करेगा।

नीचे दिए गए आरेख में, एक प्रोसेसर 2 तत्वों के लिए भंडारण के साथ बनाया गया है, जिसे वह तुरंत अपने स्रोत से अनुरोध करता है। इसलिए, जब पहला पर्यवेक्षक इसकी सदस्यता लेता है, तो यह तुरंत बफर की सामग्री को जारी करता है, जो तुरंत नई घटनाओं से भर जाता है। टर्मिनल घटना के बाद, मल्टीकास्टप्रोसेसर अपने भंडारण को साफ करता है और नए ग्राहकों को तुरंत स्ट्रीम पूरा होने की सूचना मिलती है।