प्रतिक्रियाशील पर्यवेक्षण सदस्यता निपटान

Question

यदि मेरे पास एक IObservable तक पहुंच है जो मुझे पता है कि केवल एक आइटम लौटने वाला है, तो यह काम करेगा और यह सबसे अच्छा उपयोग पैटर्न होगा?

IDisposable disposable = null; 
disposable = myObservable.Subscribe(x => 
    { 
    DoThingWithItem(x); 
    if (disposable != null) 
    { 
     disposable.Dispose(); 
    } 
    }); 

Answer 1

अस्वीकरण: मैं अभी भी आरएक्स सीख रहा हूं। इसलिए मैं वास्तव में एक विशेषज्ञ नहीं हूं लेकिन मेरा मानना ​​है कि द्वारा लौटाई गई डिस्पोजेबल केवल सदस्यता सदस्यता समाप्त कर देगी। अगर स्रोत पूरा हो जाता है, जैसे आपके मामले में, सदस्यता रद्द हो जाती है। तो मुझे लगता है कि Dispose अनावश्यक है और इसे सुरक्षित रूप से हटाया जा सकता है।

अधिक जानकारी के लिए इस question का उत्तर देखें।

Answer 2

Take फ़ंक्शन ठीक वही करेगा जो आप खोज रहे हैं। इस मामले में, Take(1)।

Answer 3

डिस्पोजेबल Subscribe विस्तार तरीकों से लौटे तो आप मैन्युअल नमूदार स्वाभाविक रूप से पहले समाप्त हो नमूदार से सदस्यता समाप्त करने की अनुमति देने के लिए पूरी तरह से दिया जाता है।

यदि अवलोकन योग्य हो - OnCompleted या OnError के साथ - तो सदस्यता पहले से ही आपके लिए निपटाई गई है। आप चलाते हैं तो आप के ऊपर है कि देखेंगे

var xs = Observable.Create<int>(o => 
{ 
    var d = Observable.Return(1).Subscribe(o); 
    return Disposable.Create(() => 
    { 
     Console.WriteLine("Disposed!"); 
     d.Dispose(); 
    }); 
}); 

var subscription = xs.Subscribe(x => Console.WriteLine(x)); 

:

इस कोड का प्रयास करें "निपटाई गई!" कंसोल पर लिखा जाता है जब सब्सक्रिप्शन को सदस्यता के बिना .Dispose() पर कॉल करने की आवश्यकता होती है।

एक महत्वपूर्ण बात गौर करने योग्य कचरा कलेक्टर कभी नहीं नमूदार सदस्यता पर .Dispose() कहता है, तो आप वे नहीं किया है अपनी सदस्यताओं की चाहिए निपटाने (या नहीं हो सकता है) स्वाभाविक रूप से समाप्त हो गया से पहले अपनी सदस्यता क्षेत्र से बाहर चला जाता है।

यह लो, उदाहरण के लिए:

var wc = new WebClient(); 

var ds = Observable 
    .FromEventPattern< 
     DownloadStringCompletedEventHandler, 
     DownloadStringCompletedEventArgs>(
      h => wc.DownloadStringCompleted += h, 
      h => wc.DownloadStringCompleted -= h); 

var subscription = 
    ds.Subscribe(d => 
     Console.WriteLine(d.EventArgs.Result)); 

ds नमूदार केवल ईवेंट हैंडलर को जोड़ देती है, जब यह एक सदस्यता है और केवल अलग होगा जब नमूदार पूर्ण करता है या सदस्यता का निपटारा किया जाता है। चूंकि यह एक ईवेंट हैंडलर है, अवलोकन करने योग्य कभी पूरा नहीं होगा क्योंकि यह अधिक घटनाओं की प्रतीक्षा कर रहा है, और इसीलिए घटना से अलग होने का एकमात्र तरीका है (उपरोक्त उदाहरण के लिए)।

जब आप एक FromEventPattern नमूदार आप जानते हैं कि केवल कभी एक मान प्रदान करेंगे तो यह ईवेंट हैंडलर स्वचालित रूप से अलग करने की अनुमति के लिए सदस्यता लेने से पहले .Take(1) विस्तार विधि को जोड़ने के लिए और फिर आप मैन्युअल रूप से के निपटान के लिए की जरूरत नहीं है बुद्धिमान है सदस्यता

तो जैसा

:

var ds = Observable 
    .FromEventPattern< 
     DownloadStringCompletedEventHandler, 
     DownloadStringCompletedEventArgs>(
      h => wc.DownloadStringCompleted += h, 
      h => wc.DownloadStringCompleted -= h) 
    .Take(1); 

मुझे आशा है कि इस मदद करता है।

Answer 4

कुछ टिप्पणियों के विपरीत यह OnNext के अंदर से सदस्यता का निपटान करने के लिए बिल्कुल असामान्य नहीं है।

हालांकि यह सच है कि OnCompleted और OnError पर निपटान एक लिपटे सदस्यता Subscribe विस्तार विधि बनाता द्वारा आप के लिए किया जाता है, तो आप एक मूल्य आप देख रहे हैं के आधार पर सदस्यता समाप्त करने के लिए कर सकते हैं (आपके मामले में की तरह: 1 एक) । आपके पास हमेशा एक अवलोकन योग्य नहीं होता है जो केवल एक मान उत्पन्न करने के लिए जाना जाता है।

समस्या यह है कि आप सदस्यता लेने के बाद ही IDisposable प्राप्त करते हैं। एक पर्यवेक्षक आपको OnNext पर वापस कॉल कर सकता है इससे पहले कि यह आपको IDisposable सदस्यता समाप्त करने के लिए वापस लौटाए (IScheduler जैसी चीजों के आधार पर)।

System.Reactive.Disposables.SingleAssignmentDisposable इस मामले में काम में आता है। यह IDisposable को लपेटता है जिसे आप देर से असाइन कर सकते हैं, और SingleAssignmentDisposable को पहले से ही निपटान कर दिया गया है, तो इसे तुरंत असाइनमेंट पर निपटान कर देगा। इसके अलावा इसमें एक संपत्ति IsDisposed है जो प्रारंभ में false है और true पर सेट है जब Dispose() कहा जाता है।

तो:

IObservable<string> source = ...; 

var subscription = new SingleAssignmentDisposable(); 
subscription.Disposable = source.Subscribe(x => 
{ 
    if (subscription.IsDisposed) // getting notified though I've told it to stop 
     return; 
    DoThingsWithItem(x); 
    if (x == "the last item I'm interested in") 
     subscription.Dispose(); 
});