एक व्यवहार विषय

Question

मैं एक व्यवहार विषय

var source = new BehaviorSubject<int>(0); 

मैं तो प्रक्रिया है पर अपवाद को संभालने के लिए कैसे इस तरह

var withErrors = source 
      .Select(v => 
      { 
       if (v == 2) 
       { 
        throw new Exception("Ouch "); 
       } 
       return v; 
      }) 

मैं इस तरह से withErrors की सदस्यता के लिए चाहते हैं कुछ के साथ स्रोत है कि मैं त्रुटियों को छोड़ सकते हैं। इस तरह पकड़ने के साथ एक प्रयास।

public IObservabe<int> SkipError(IObservable<T> source){ 

    return source 
     .Catch(e=>SkipErrors(source.Skip(1)); 
} 

और फिर इसे कहते इस प्रकार

var withoutErrors = SkipError(withErrors); 

छोड़ें व्यवहार विषय पर पिछले त्रुटि दोहराने से बचें करने का प्रयास है, लेकिन अफसोस यह कि जिस तरह से काम नहीं करता। छोड़ें त्रुटियों पर छोड़ नहीं है बल्कि केवल वैध डेटा पर है, इसलिए व्यवहार विषय में वर्तमान स्थिति से त्रुटि प्राप्त हो रही है।

क्या लेखन का एक चालाक तरीका है छोड़ें जो त्रुटियों पर भी छोड़ देगा। कुछ मुझे बताता है कि यह संभव नहीं है लेकिन उम्मीद है कि मैं गलत हूं

Answer 1

प्रश्न के आधार पर गलत है, मैं Exceptional<T> मोनैड का उपयोग करके ऐसा करने के लिए better तरीका प्रस्तुत करता हूं। उदाहरण

IObservable<int> source = ....; 
IObservable<Exceptional<string>> withErrors = 
    source.Select(i=>Exceptional.Execute(()=>{ 
     if(v==2){ 
      throw new Exception("Ouch"); 
     } 
     return v.ToString(); 
    }); 


IObservable<Exception> errors = 
    withErrors.Where(v=>v.HasException).select(v=>v.Exception); 

IObservable<string> values = 
    withErrors.Where(v=>!v.HasException).select(v=>v.Value); 

के लिए और सिर्फ मनोरंजन के लिए आप

Exceptional<string> r = 
     from x in Exceptional.Execute(() => "xxx") 
     from y in Exceptional.Execute(() => "zzz") 
     select x + y; 

कर सकते हैं जो एक पीढ़ी होगा एक असाधारण मूल्य "xxxzzz" पकड़े। यदि कोई भी कदम अपवाद फेंकता है तो यह शॉर्ट सर्किट होगा और केवल अपवाद ही होगा।

मेरे कार्यान्वयन पर आधारित एक और तो जवाब https://gist.github.com/bradphelan/6154972