😰 🏡 🤱 Apple कम्बाइन का उपयोग करके दूरस्थ अतुल्यकालिक लाने के लिए एपीआई 👍🏻 🙊 👨‍👨‍👦

कंबाइन एक कार्यात्मक प्रतिक्रियाशील Swift फ्रेमवर्क है जिसे हाल ही में Xcode 11 सहित सभी Apple प्लेटफार्मों के लिए लागू किया गया है। कंबाइन के साथ , समय के साथ अतुल्यकालिक रूप से दिखाई देने वाले मूल्यों के अनुक्रम को संसाधित करना बहुत आसान है। यह प्रतिनिधिमंडल और जटिल नेस्टेड कॉलबैक को छोड़कर अतुल्यकालिक कोड को भी सरल करता है।

लेकिन पहली बार में कॉम्बिनेशन का अध्ययन करना इतना सरल नहीं हो सकता है। तथ्य यह है कि कॉम्बाइन के मुख्य "खिलाड़ी" "प्रकाशक" प्रकाशक , "सब्सक्राइबर" सब्सक्राइबर और ऑपरेटर के रूप में ऐसी अमूर्त अवधारणाएं हैं, जिनके बिना कॉम्बिनेशन के तर्क को समझने के लिए आगे बढ़ना संभव नहीं होगा। हालांकि, इस तथ्य के कारण कि Apple तैयार-किए गए "प्रकाशकों", "ग्राहकों" और ऑपरेटरों के साथ डेवलपर्स प्रदान करता है, कॉम्बाइन के साथ लिखा गया कोड बहुत कॉम्पैक्ट और अच्छी तरह से पठनीय है।

अब आप इसे बहुत लोकप्रिय TMDb डेटाबेस से अतुल्यकालिक रूप से मूवी की जानकारी को पुनः प्राप्त करने से संबंधित एप्लिकेशन के उदाहरण में देखेंगे। हम दो अलग-अलग एप्लिकेशन बनाएंगे: UIKit और SwiftUI , और बताएंगे कि कॉम्बाइन उनके साथ कैसे काम करता है।

मुझे उम्मीद है कि इस लेख से आपको कॉम्बिनेशन सीखने में आसानी होगी। इस लेख में विकसित सभी अनुप्रयोगों के लिए कोड जीथब पर पाया जा सकता है।

कंबाइन के कई मुख्य घटक हैं:

प्रकाशक प्रकाशक ।

प्रकाशकों के प्रकाशक TYPES हैं जो उन सभी को मान प्रदान करते हैं जो परवाह करते हैं। प्रकाशक की "प्रकाशक" अवधारणा को एक विशेष TYPE के रूप में एक प्रोटोकॉल के रूप में लागू किया गया है। प्रकाशक प्रोटोकॉल में आउटपुट मूल्य और विफलता त्रुटि के लिए जेनेरिक TYPES जुड़े हुए हैं।
एक "प्रकाशक" जो कभी भी त्रुटि प्रकाशित नहीं करता है, विफलता के लिए TYPE Never का उपयोग करता है।

Apple तैयार-किए गए "प्रकाशकों" के विशिष्ट कार्यान्वयन के साथ डेवलपर्स प्रदान करता है: बस , भविष्य , खाली , स्थगित , अनुक्रम , @ प्रकाशित , आदि। "प्रकाशक" को फ़ाउंडेशन क्लासेस में भी जोड़ा जाता है: URLSession , < NotificationCenter , टाइमर ।

"सब्सक्राइबर" सब्सक्राइबर ।

यह एक प्रोटोकॉल प्रोटोकॉल भी है जो एक "प्रकाशक" से मूल्यों के लिए "सदस्यता" के लिए एक इंटरफ़ेस प्रदान करता है। इसमें इनपुट और विफलता त्रुटियों के लिए जेनेरिक TYPES जुड़े हुए हैं। जाहिर है, प्रकाशक प्रकाशक और सब्सक्राइबर सब्सक्राइबर का TYPES मेल खाना चाहिए।

किसी भी प्रकाशक प्रकाशक के लिए, दो अंतर्निहित ग्राहक हैं : सिंक और असाइन करें :

"सब्सक्राइबर" सिंक दो क्लोजर पर आधारित होता है: एक क्लोजर, रिसीव्यू , निष्पादित होने पर निष्पादित किया जाता है, जब आप " पब्लिशिंग " (सामान्य रूप से या एक त्रुटि के साथ) पूरा हो जाता है , तो दूसरी क्लोजर, रिसीप्लिमेंटेशन को निष्पादित किया जाता है।

"सब्सक्राइबर" असाइन , निर्दिष्ट key Path ओर प्राप्त प्रत्येक मूल्य को आगे बढ़ाता है।

"सदस्यता" सदस्यता ।

सबसे पहले, "प्रकाशक" प्रकाशक " प्राप्तकर्ता " सबस्क्राइबर को " प्राप्त " सब्सक्राइबर को उसके प्राप्त (सदस्यता :) विधि के माध्यम से बनाता और वितरित करता है:

उसके बाद, सदस्यता दो तरीकों का उपयोग करके सब्सक्राइबर्स के "ग्राहकों" को अपना मान भेज सकती है:

यदि आपने सदस्यता सदस्यता के साथ काम करना समाप्त कर लिया है, तो आप इसकी रद्द () विधि को कॉल कर सकते हैं:

"विषय" विषय ।

यह एक प्रोटोकॉल प्रोटोकॉल है जो दोनों ग्राहकों के लिए, "प्रकाशक" और "सब्सक्राइबर" दोनों के लिए एक इंटरफ़ेस प्रदान करता है। अनिवार्य रूप से, "विषय" विषय "प्रकाशक" प्रकाशक है , जो इनपुट मूल्य इनपुट को स्वीकार कर सकता है और जिसे आप भेजने () विधि को कॉल करके मानों को धारा में "इंजेक्ट" कर सकते हैं। कम्बाइन मॉडल्स में मौजूदा अनिवार्यता कोड को लागू करते समय यह उपयोगी हो सकता है।

संचालक परिचालक ।

ऑपरेटर का उपयोग करके, आप एक और प्रकाशक "प्रकाशक" से एक नया प्रकाशक "प्रकाशक" बना सकते हैं, कई पिछले upstream पब्लिशर्स से कन्वर्ज़न, फ़िल्टरिंग और यहां तक कि वैल्यूज़ को जोड़कर।

आप यहां बहुत सारे परिचित ऑपरेटर नाम देख रहे हैं: कॉम्पैक्ट मैप , मैप , फ़िल्टर , ड्रॉप फ़र्स्ट , एपेंड ।

फाउंडेशन प्रकाशक पब्लिशर्स फाउंडेशन में बनाया।

Apple , फाउंडेशन < ढ्डह्म > में कई पहले से निर्मित कंबाइन फंक्शंस के साथ डेवलपर्स को प्रदान करता है, जो कि पब्लिशर्स पब्लिशर्स हैं, जो URLSession का उपयोग करके डेटा लाने जैसे कार्यों के लिए, नोटिफिकेशन , टाइमर का उपयोग करते हुए नोटिफिकेशन के साथ काम करते हैं , और KVO पर आधारित गुणों की निगरानी करते हैं। यह अंतर्निहित संगतता वास्तव में हमारी वर्तमान परियोजना में कंबाइन ढांचे को एकीकृत करने में हमारी मदद करेगी।
इसके बारे में अधिक जानने के लिए, "स्विफ्ट में अंतिम संयोजन रूपरेखा ट्यूटोरियल" लेख देखें।

हम कंबाइन के साथ क्या करना सीखते हैं?

इस लेख में, हम यह सीखेंगे कि टीएमडीबी वेबसाइट से मूवी डेटा लाने के लिए कंबाइन फ्रेमवर्क का उपयोग कैसे करें। यहाँ हम एक साथ अध्ययन करेंगे:

"प्रकाशक" भविष्य का उपयोग करके एकल मूल्य के लिए वादा के साथ एक करीबी बनाने के लिए: या तो मूल्य या त्रुटि।
किसी दिए गए UR L द्वारा प्रकाशित डेटा डेटा के लिए "प्रकाशक" URLSession.datataskPublisher का उपयोग करके "सदस्यता" लें।
किसी अन्य प्रकाशक प्रकाशक का उपयोग करके डेटा डेटा को परिवर्तित करने के लिए tryMap ऑपरेटर का उपयोग करना।
डिकोड ऑपरेटर का उपयोग डेटा डेटा को डिकोडेबल ऑब्जेक्ट में बदलने और चेन के बाद के तत्वों तक संचरण के लिए प्रकाशित करना है।
बंद करने का उपयोग करके प्रकाशक "प्रकाशक" को "सदस्यता" के लिए सिंक ऑपरेटर का उपयोग करना।
प्रकाशक "प्रकाशक" को "सदस्यता" के लिए दिए गए कथन का उपयोग करें और दिए गए key Path को इसकी आपूर्ति करें।

प्रारंभिक परियोजना

शुरू करने से पहले, हमें TMDb वेबसाइट पर API कुंजी प्राप्त करने के लिए रजिस्टर करना होगा। आपको GitHub रिपॉजिटरी से प्रारंभिक प्रोजेक्ट डाउनलोड करने की भी आवश्यकता है।
सुनिश्चित करें कि आप अपनी API कुंजी को मूवीस्टोर क्लास में एपीके स्थिरांक में रखें।

यहां मुख्य बिल्डिंग ब्लॉक हैं जिनसे हम अपनी परियोजना बनाएंगे:

1. Movie.swift अंदर। Movie.swift फ़ाइल ऐसे मॉडल हैं जिनका उपयोग हम अपने प्रोजेक्ट में करेंगे। स्ट्रक्चरल मूवीस्पेस की मूल संरचना डिकोडेबल प्रोटोकॉल को लागू करती है, और JSON डेटा को मॉडल में डिकोड करने पर हम इसका उपयोग करेंगे। MoviesResponse संरचना में एक परिणाम संपत्ति होती है, जो डिकोडेबल प्रोटोकॉल को लागू करती है और फिल्मों का संग्रह है [मूवी] । यह वह है जो हमें रुचता है:

2. Enum गणन MovieStoreAPIError त्रुटि प्रोटोकॉल को लागू करता है। हमारी API इस गणना का उपयोग विभिन्न प्रकार की त्रुटियों का प्रतिनिधित्व करने के लिए करेगी: URL पुनर्प्राप्ति त्रुटियां urlError , decodingError डिकोडिंग त्रुटियां, और प्रतिसाद डेटा डेटा त्रुटियाँ प्राप्त करना।

3. हमारे API में एक एकल विधि के साथ एक मूवी सर्विस प्रोटोकॉल है, भ्रूण (एंडपॉइंट से: एंडपॉइंट) , जो एंडपॉइंट पैरामीटर के आधार पर [मूवी] फिल्मों का चयन करता है। समापन बिंदु स्वयं एक एनम एनम है जो TMPb डेटाबेस तक पहुँचने के लिए एक एंडपॉइंट का प्रतिनिधित्व करता है जैसे कि अब फिल्में (नवीनतम), लोकप्रिय (लोकप्रिय), टॉप रेटेड (शीर्ष) और आगामी (स्क्रीन पर जल्द ही आने वाली )।

4. मूवीस्टोर क्लास एक विशिष्ट वर्ग है जो TMDb साइट से डेटा लाने के लिए मूवी सर्विस प्रोटोकॉल को लागू करता है। इस वर्ग के अंदर, हम कॉम्बिनेशन का उपयोग करके fetchMovies (...) पद्धति को लागू करते हैं।

5. MovieListViewController क्लास मुख्य ViewController क्लास है, जिसमें हम fetchMovies (...) मूवी लाने के लिए सिंक विधि का उपयोग करते हैं, जो भविष्य का "प्रकाशक" लौटाता है, और फिर नए मूवी डेटा के साथ TableView टेबल अपडेट करें नई DiffableDataSourceSnapshot API का उपयोग करके फिल्में ।

आरंभ करने से पहले, आइए हम कुछ बुनियादी संयोजन घटकों को देखें जिनका उपयोग हम दूरस्थ डेटा पुनर्प्राप्ति API ।

सिंक और इसके क्लोजर का उपयोग करके "प्रकाशक" के लिए "सदस्यता लें"।

प्रकाशक के "प्रकाशक" को "सब्सक्राइब" करने का सबसे आसान तरीका यह है कि इसके क्लोजर के साथ सिंक का उपयोग किया जाए, जिनमें से एक को जब भी हम एक नया मूल्य प्राप्त करेंगे, और दूसरे को "प्रकाशक" मानों को वितरित करते हुए समाप्त किया जाएगा।

याद रखें कि कंबाइन में, प्रत्येक "सदस्यता" एक कैंसेलेबल देता है, जो कि जैसे ही हम अपना संदर्भ छोड़ते हैं, हटा दिया जाएगा। उदाहरण के लिए, अधिक समय तक "सदस्यता" बनाए रखने के लिए, अतुल्यकालिक मूल्यों को प्राप्त करने के लिए, हमें सबस्क्रिप्शन 1 संपत्ति में "सदस्यता" को बचाने की आवश्यकता है। इससे हमें सभी मूल्यों (7,8,3,4) को लगातार प्राप्त करने की अनुमति मिली ।

भविष्य में अतुल्यकालिक रूप से "एकल" प्रकाशित करता है: या तो मूल्य या विफलता त्रुटि।

कंबाइन फ्रेमवर्क में, "प्रकाशक" फ्यूचर को एक क्लोजर का उपयोग करके अतुल्यकालिक रूप से एकल TYPE परिणाम प्राप्त करने के लिए इस्तेमाल किया जा सकता है। बंद करने का एक पैरामीटर है - वादा , जो TYPE (परिणाम <आउटपुट, विफलता>) का एक फ़ंक्शन है -> शून्य ।

आइए भविष्य के प्रकाशक के कार्यों को समझने के लिए एक सरल उदाहरण देखें:

हम TYPE Int के सफल परिणाम और TYPE Never की त्रुटि के साथ Future बनाते हैं। फ्यूचर क्लोजर के अंदर, हम कोड के निष्पादन में 2 सेकंड की देरी के लिए DispatchQueue.main.asyncAfter (...) का उपयोग करते हैं, जिससे अतुल्यकालिक व्यवहार का अनुकरण होता है। बंद होने के अंदर, हम 0 और 100 के बीच सीमा में एक यादृच्छिक पूर्णांक इंट मान के रूप में वादे के सफल परिणाम (.success (...)) के साथ वादा करते हैं। अगला, हम दो भावी सदस्यताएँ - रद्द करने योग्य और रद्द करने योग्य 1 का उपयोग करते हैं - और दोनों एक ही परिणाम देते हैं, हालांकि अंदर एक यादृच्छिक संख्या उत्पन्न होती है।

1. यह 1. दिया जाना चाहिए कि संयोजन में भविष्य के "प्रकाशक" में अन्य "प्रकाशकों" की तुलना में कुछ व्यवहार विशेषताएं हैं:

"प्रकाशक" भविष्य हमेशा "एक मूल्य ( मूल्य या त्रुटि)" प्रकाशित करता है, और यह अपना काम पूरा करता है।

भविष्य "प्रकाशक" एक वर्ग ( reference type ) वर्ग है, अन्य "प्रकाशकों" के विपरीत, जो मुख्य रूप से संरचना ( value type ) संरचनाएं हैं, और यह वादा बंद हो जाता है, जो कि भविष्य में "प्रकाशक" उदाहरण के पैरामीटर के रूप में, तुरंत बनाया जाता है। यही है, वादा बंद होने से पहले किसी भी ग्राहक " सब्सक्राइबर " को भविष्य में "प्रकाशक" उदाहरण के लिए सबस्क्राइब किया जाता है। भविष्य के "प्रकाशक" को अपने कामकाज के लिए "सब्सक्राइबर" की आवश्यकता नहीं है, क्योंकि अन्य सभी सामान्य प्रकाशकों की आवश्यकता है। यही कारण है कि पाठ "भविष्य के अंदर से नमस्कार!" उपरोक्त कोड में केवल एक बार मुद्रित होता है।

अधिकांश अन्य आलसी "प्रकाशकों" ("प्रकाशित करें" केवल "सदस्यता" होने पर) "प्रकाशक" एक eager (अधीर) "प्रकाशक" है। केवल एक बार भविष्य के प्रकाशक ने अपना वादा बंद कर दिया, परिणाम को याद किया जाता है और फिर वर्तमान और भविष्य के "ग्राहकों" को दिया जाता है। उपरोक्त कोड से, हम देखते हैं कि जब आप भविष्य के प्रकाशक को बार-बार "सब्सक्राइब" करते हैं , तो आपको हमेशा एक ही "रैंडम" वैल्यू मिलती है (इस मामले में 6 , लेकिन यह अलग-अलग हो सकती है, लेकिन हमेशा एक जैसी ही), हालाँकि इसका उपयोग क्लोजर में किया जाता है यादृच्छिक int मान।

"प्रकाशक" भविष्य का ऐसा तर्क आपको एक अतुल्यकालिक संसाधन-खपत की गणना के परिणाम को याद करने और बाद में कई "सदस्यता" के लिए "सर्वर" को परेशान न करने के लिए सफलतापूर्वक इसका उपयोग करने की अनुमति देता है।

यदि भविष्य के "प्रकाशक" का ऐसा तर्क आपको शोभा नहीं देता है और आप चाहते हैं कि आपका भविष्य आलसी कहलाए और हर बार जब आपको नए यादृच्छिक इंट्यू वैल्यू मिलते हैं, तो आपको भविष्य को " आस्थगित " करना चाहिए:

हम भविष्य को एक क्लासिक तरीके से उपयोग करेंगे, जैसा कि कॉम्बाइन में सुझाया गया है, अर्थात् , "साझा" अतुल्यकालिक "प्रकाशित" गणना के रूप में।

नोट 2. हमें एसिंक्रोनस "प्रकाशक" के लिए सिंक का उपयोग करके "सदस्यता" के बारे में एक और टिप्पणी करने की आवश्यकता है। सिंक विधि AnyCancellable को लौटाता है, जिसे हम लगातार याद नहीं करते हैं। इसका मतलब यह है कि Swift भी समय आपके द्वारा दिए गए संदर्भ को छोड़ देगा, जो कि main thread पर होता है। इस प्रकार, यह पता चला है कि AnyCancellable main thread पर शुरू होने के साथ बंद होने से पहले नष्ट हो जाता है। जब AnyCancellable नष्ट हो जाता है, तो उसका रद्द करने का तरीका कहा जाता है, जो इस मामले में "सदस्यता" को रद्द कर देता है। यही कारण है कि हम भविष्य में अपने सिंक "सब्सक्रिप्शन" को कैंसिलेबल <और cancellable1 या सेट <AnyCancellable> () में भविष्य के लिए याद करते हैं ।

टीएमडीबी वेबसाइट से फिल्में लाने के लिए कंबाइन का उपयोग करना।

शुरुआत करने के लिए, आप स्टार्टर प्रोजेक्ट को MovieStore.swift हैं और एक खाली कार्यान्वयन के साथ MovieStore.swift फाइल और भ्रूणमोविज़ विधि पर जाते हैं:

FetchMovies पद्धति का उपयोग करके , हम TYPE समापन बिंदु के समापन बिंदु इनपुट पैरामीटर के लिए विशिष्ट मान सेट करके विभिन्न फिल्मों का चयन कर सकते हैं। TYPE समापन बिंदु एक एनुम एन्यूमरेशन है जो अब मान लेता है (वर्तमान), आगामी (जल्द ही स्क्रीन पर आ रहा है), लोकप्रिय (लोकप्रिय), टॉप रेटेड (शीर्ष):

चलिए एक callback क्लोजर के साथ भविष्य की शुरुआत करते हैं। प्राप्त भविष्य हम फिर धनवापसी करेंगे।

callback बंद होने के अंदर, हम जनरेट का उपयोग करके एंडपॉइंट इनपुट पैरामीटर के संगत मान के लिए जनरेट उत्पन्न करते हैं (एंडपॉइंट के साथ: एंडपॉइंट) फ़ंक्शन:

यदि सही URL जेनरेट नहीं किया जा सकता है, तो हम वादे (.failure (.urlError (...)) का उपयोग करके एक त्रुटि लौटाते हैं , अन्यथा हम आगे बढ़ते हैं और "प्रकाशक" URLSession.dataTaskPublisher को लागू करते हैं।

एक निश्चित URL से डेटा को "सब्स्क्राइब" करने के लिए URL हम URL सेशन वर्ग में निर्मित डेटाटास्कप्रोसेसर विधि का उपयोग कर सकते हैं, जो URL को एक पैरामीटर के रूप में प्राप्त करता है और ट्यूल के आउटपुट डेटा (डेटा: डेटा, प्रतिक्रिया: URLResponse) और URLError त्रुटि के साथ प्रकाशक "प्रकाशक" को लौटाता है।

एक प्रकाशक प्रकाशक को दूसरे प्रकाशक प्रकाशक में परिवर्तित करने के लिए, ट्राइपॉपर ऑपरेटर का उपयोग करें। मानचित्र की तुलना में, ट्राइपॉपर ऑपरेटर एक बंद के अंदर एक थ्रो एरर एरर फेंक सकता है, जो हमें नया प्रकाशक प्रकाशक लौटाता है।

अगले चरण में, हम tryMap ऑपरेटर का उपयोग करके स्थिति प्रतिक्रिया की स्थिति कोड की http कोड की जांच करेंगे ताकि यह सुनिश्चित किया जा सके कि इसका मान 200 और 300 के बीच है। यदि नहीं, तो हम फेंकता है responserrror enum MovieStoreAPIError गणन त्रुटि मान। अन्यथा (जब कोई त्रुटि नहीं होती है), हम केवल प्राप्त डेटा डेटा को "प्रकाशक" श्रृंखला के अगले प्रकाशक को वापस कर देते हैं।

अगले चरण में, हम डिकोड ऑपरेटर का उपयोग करेंगे, जो पिछले "पब्लिशर" के आउटपुट JSON डेटा को फिल्मरस्पेस <मॉडल में JSONDecoder का उपयोग करते हुए MovieResponse <Model में आउटपुट करता है ।

... jsonDecoder एक विशिष्ट तिथि प्रारूप के लिए कॉन्फ़िगर किया गया है:

main thread पर प्रदर्शन की जाने वाली प्रक्रिया के लिए, हम प्राप्त (ऑन :) ऑपरेटर का उपयोग करेंगे और इसके इनपुट पैरामीटर के रूप में RunLoop.main पास करेंगे। यह "ग्राहक" को main धागे पर मूल्य मान प्राप्त करने की अनुमति देगा।

अंत में, हम अपनी परिवर्तन श्रृंखला के अंत में पहुंच गए, और वहां हम पब्लिशर्स "प्रकाशकों" की गठित "श्रृंखला" के लिए "सदस्यता" सदस्यता प्राप्त करने के लिए सिंक का उपयोग करते हैं। सिंक क्लास का एक उदाहरण शुरू करने के लिए, हमें दो चीजों की आवश्यकता है, हालांकि उनमें से एक वैकल्पिक है:

बंद प्राप्त जब भी "प्रकाशक" प्रकाशक से नया मान प्राप्त होता है तो उसे "प्रकाशक" प्रकाशक कहा जाएगा ।

getCompletion बंद करना : (वैकल्पिक)। इसे प्रकाशक "प्रकाशक" द्वारा प्रकाशन के बाद समाप्त कर दिया जाएगा, इसे पूर्ण गणना कहा जाएगा, जिसका उपयोग हम यह जांचने के लिए कर सकते हैं कि मानों का "प्रकाशन" वास्तव में पूरा हो गया है या पूरा होने में त्रुटि हुई है।

ReceValue बंद होने के अंदर, हम बस एक असफल विकल्प और $ 0.results के मूल्य के साथ एक वादा करते हैं, जो हमारे मामले में फिल्मों की एक सरणी है। GetCompletion बंद होने के अंदर , हम जाँचते हैं कि यदि पूर्णता में कोई त्रुटि है , तो .failure विकल्प के साथ संबंधित वादा त्रुटि पास करें।

ध्यान दें कि यहाँ हम सभी त्रुटियों को "प्रकाशक श्रृंखला" के पिछले चरणों में एकत्र करते हैं।

इसके बाद, हम सेट <AnyCancellable> () संपत्ति में "सदस्यता" सदस्यता को याद करते हैं।
तथ्य यह है कि "सदस्यता" सदस्यता रद्द करने योग्य है , यह एक ऐसा प्रोटोकॉल है जो भ्रूण के कार्य के पूरा होने के बाद सब कुछ नष्ट कर देता है और साफ करता है। इस फ़ंक्शन के पूरा होने के बाद भी "सब्सक्रिप्शन" सदस्यता के संरक्षण की गारंटी देने के लिए, हमें भ्रूण मेमोविज़ फ़ंक्शन के लिए चर बाहरी में "सदस्यता" सदस्यता को याद रखना होगा। हमारे मामले में, हम सदस्यता संपत्ति का उपयोग करते हैं, जिसमें सेट <AnyCancellable> () प्रकार है और .store (में: और self.subscos) विधि का उपयोग करें , जो कि भ्रूण के कार्य के बाद "सदस्यता" की प्रयोज्यता सुनिश्चित करता है।

यह कॉम्बिनेशन फ्रेमवर्क का उपयोग करके TMDb डेटाबेस से फिल्में चुनने के लिए fetchMovies विधि के गठन का निष्कर्ष निकालता है। भ्रूण पैरामीटर विधि, इनपुट पैरामीटर के रूप में, एनम समापन बिंदु गणना का मान लेता है, अर्थात, कौन सी विशिष्ट फिल्में हमारे लिए रुचि रखती हैं:

.nowPlaying - वर्तमान में स्क्रीन पर आने वाली फिल्में,
.upcoming - फिल्में जो जल्द ही आ रही हैं।
। पॉपुलर - लोकप्रिय फिल्में,
.topRated - शीर्ष फिल्में, जो बहुत उच्च रेटिंग के साथ हैं।
आइए इस API को एप्लिकेशन डिज़ाइन के लिए सामान्य यूआईकिट उपयोगकर्ता इंटरफेस के साथ Table View Controller के रूप में लागू करने का प्रयास करें:

और एक एप्लिकेशन जिसका यूजर इंटरफेस नई घोषणात्मक स्विफ्टयूई फ्रेमवर्क का उपयोग करके बनाया गया है:

"सामान्य `View Controller` फिल्मों से फिल्मों की सदस्यता लें"।

हम MovieListViewController.swift फ़ाइल पर जाते हैं और व्यूडॉलड विधि में fetMMies विधि कहते हैं।

हमारे fetchMovies विधि के अंदर , हम पहले से विकसित फिल्मएपीआई का उपयोग करते हैं और इसकी fetchMovies पद्धति का उपयोग इनपुट पैरामीटर से समापन बिंदु के रूप में .Playing पैरामीटर के साथ किया जाता है। यही है, हम उन फिल्मों का चयन करेंगे जो वर्तमान में मूवी थिएटर की स्क्रीन पर हैं।

MovieAPI.fetchMovies (से: .nowPlaying) विधि फ्यूचर "प्रकाशक" को लौटाती है, जिसके लिए हम सिंक का उपयोग करके "सब्सक्राइब" करते हैं, और दो क्लोजर के साथ इसकी आपूर्ति करते हैं। ReceCompletion बंद करने में, हम जाँचते हैं कि क्या कोई त्रुटि है और प्रदर्शित होने वाले त्रुटि संदेश के साथ उपयोगकर्ता चेतावनी के लिए आपातकालीन चेतावनी प्रदर्शित करता है।

ReceValue क्लोजर में , हम जेनरेटनशॉट विधि को कॉल करते हैं और चयनित फिल्मों को इसे पास करते हैं।

GenerSnapshot फ़ंक्शन हमारी फिल्मों का उपयोग करके एक नया NSDiffableDataSourceSnapshot बनाता है , और परिणामी स्नैपशॉट को हमारी तालिका के diffableDataSource पर लागू करता है।

हम एप्लिकेशन लॉन्च करते हैं और देखते हैं कि कैसे UIKit कंबाइन ढांचे से "प्रकाशकों" और "ग्राहकों" के साथ काम करता है। यह एक बहुत ही सरल अनुप्रयोग है जो आपको फिल्मों के विभिन्न संग्रहों में धुन करने की अनुमति नहीं देता है - अब स्क्रीन पर दिखाया जाता है, लोकप्रिय, उच्च-रेटेड या जो निकट भविष्य में स्क्रीन पर दिखाई देने वाले हैं। हम केवल उन फिल्मों को देखते हैं जो स्क्रीन पर दिखाई देने वाली हैं ( .upcoming )। बेशक, आप समापन बिंदु गणना के मूल्यों को सेट करने के लिए किसी भी UI तत्व को जोड़कर ऐसा कर सकते हैं, उदाहरण के लिए, Stepper या Segmented Control का उपयोग करके, और फिर उपयोगकर्ता इंटरफ़ेस को अपडेट करें। यह सर्वविदित है, लेकिन हम इसे UIKit- आधारित एप्लिकेशन में नहीं करेंगे, लेकिन इसे नई घोषणात्मक SwiftUI ढांचे पर छोड़ दें।
एक UIKit- आधारित एप्लिकेशन के लिए कोड Gineub पर CombineFetchAPICompleted-UIKit में पाया जा सकता है।

फिल्मों का प्रदर्शन करने के लिए SwiftUI का उपयोग करें

।
CombineFetchAPI-MY SwiftUI File -> New -> Project Single View App iOS :

UI — SwiftUI :

Movie.swift Model , TMDb MovieStore.swift , MovieStoreAPIError.swift MovieService.swift , MovieService Protocol :

SwiftUI , Codable , JSON , Identifiable , [Movie] List . SwiftUI Equatable Hashable , UIKit API UITableViewDiffableDataSource UIKit . < struct Movie , Equatable Hashable :

........................... .

Identifiable , Swift Identifiable , Hashable Equatable .

, SwiftUI , , endpoint , :

, UIKit , movieAPI.fetchMovies (from endpoint: Endpoint) , endpoint «» Future<[Movie, MovieStoreAPIError]> . Endpoint , , case Endpoint index :

, movies , indexEndpoint Endpoint . View Model , MoviesViewModel , ObservableObject . MoviesViewModel.swift View Model :

@Published : @Published var indexEndpoint: Int — , @Published var movies: [Movie] - . @Published indexEndpoint , indexEndpoint , $indexEndpoint .
MoviesViewModel «» $indexEndpoint «» AnyPublisher<[Movie], Never> , movieAPI.fetchMovies (from: Endpoint (index: indexPoint)) flatMap .

«» «» «» assing (to: \.movies, on: self) «» movies . «» assing (to: \.movies, on: self) , «» , Never . ? replaceError(with: [ ]) , movies .

SwiftUI .

, View Model , UI . ContentView.swift View Model @EnvironmentObject var moviesViewModel Text(«Hello, World!»)
Text("\(moviesViewModel.indexEndpoint)") , indexEndpoint .

View Model indexEndpoint = 2 , , ( Upcoming ):

UI , . Stepper :

… Picker :

«» $moviesViewModel.indexEndpoint View Model , ( ) :

List ForEach movie :

moviesViewModel.movies View Model :

«» $moviesViewModel.movies $ , . moviesViewModel.movies .

, , URL Movie :

Thomas Ricouard MovieSwiftUI .

movies , UIImage ImageService , Combine fetchImage , «» AnyPublisher<UIImage?, Never> :

… final class ImageLoader: ObservableObject , ObservableObject @Published image: UIImage? :

, ObservableObject - objectWillChange . SwiftUI , - , , Views , . objectWillChange , @Published . - objectWillChange . .
ImageLoader @Published var image:UIImage? । , ImageLoader , «» $image «» loadImage() , poster size @Published var image:UIImage? । objectWillChange .
, , imageLoader ImageLoader :

View MoviePosterImage :

… ContentView :

SwiftUI Github CombineFetchAPI-NOError .

.

, TMDb . movieAPI.fetchMovies (from endpoint: Endpoint) , , «» Future<[Movie, MovieStoreAPIError]> .

, , View Model @Published moviesError: MovieStoreAPIError? , . Optional , nil , :