एक अपवाद कार्यवाही

Question

से फेंक दिया जा सकता अपवाद जो मैं Rx.NET के लिए कुछ नया हूँ। क्या किसी अपवाद को पकड़ना संभव है जिसे किसी भी ग्राहक द्वारा फेंक दिया जा सकता है? निम्नलिखित ले लो ...

handler.FooStream.Subscribe(
      _ => throw new Exception("Bar"), 
      _ => { }); 

वर्तमान में मैं निम्नलिखित के उदाहरण के साथ प्रति सदस्यता आधार पर पकड़ रहा हूं। जिसका कार्यान्वयन केवल प्रतीक्षा थ्रेड उठाने के लिए मैन्युअल रीसेट इवेंट का उपयोग करता है।

public interface IExceptionCatcher 
{ 
    Action<T> Exec<T>(Action<T> action); 
} 

और इतने की तरह इसे का उपयोग ...

handler.FooStream.Subscribe(
      _exceptionCatcher.Exec<Foo>(_ => throw new Exception("Bar")), //It's disappointing that this generic type can't be inferred 
      _ => { }); 

मुझे लगता है कि वहाँ कुछ बेहतर तरीका होना चाहिए। आरएक्स.NET में विशेष रूप से त्रुटियों के अवलोकनों से निपटने के लिए सभी त्रुटि हैंडलिंग क्षमताओं क्या हैं?

संपादित करें: प्रति अनुरोध, मेरा कार्यान्वयन https://gist.github.com/1409829 (इंटरफ़ेस और कार्यान्वयन प्रोड कोड में विभिन्न असेंबली में अलग किया गया है)। प्रतिक्रिया का स्वागत है। यह मूर्खतापूर्ण प्रतीत हो सकता है, लेकिन मैं कई अलग-अलग आरएक्स ग्राहकों को प्रबंधित करने के लिए महल विंडसर का उपयोग कर रहा हूं।

var exceptionCatcher = 
    new ExceptionCatcher(e => 
           { 
            Logger.FatalException(
             "Exception caught, shutting down.", e); 
            // Deal with unmanaged resources here 
           }, false); 


/* 
* Normally the code below exists in some class managed by an IoC container. 
* 'catcher' would be provided by the container. 
*/ 
observable /* do some filtering, selecting, grouping etc */ 
    .SubscribeWithExceptionCatching(processItems, catcher); 

Answer 1

निर्मित प्रत्यक्ष ऑपरेटरों तुम क्या हो ऐसा नहीं करते हैं: यह अपवाद पकड़ने वाला इस

windsorContainer.Register(Component.For<IExceptionCatcher>().Instance(catcher)); 

तरह कंटेनर यह तो इस तरह इस्तेमाल किया जाएगा जहां observable IObservable का उदाहरण है के साथ पंजीकृत है डिफ़ॉल्ट रूप से पूछना (घटनाओं की तरह), लेकिन आप एक विस्तार विधि बना सकते हैं जो ऐसा करेगा।

public static IObservable<T> IgnoreObserverExceptions<T, TException>(
           this IObservable<T> source 
           ) where TException : Exception 
{ 
    return Observable.CreateWithDisposable<T>(
     o => source.Subscribe(
      v => { try { o.OnNext(v); } 
        catch (TException) { } 
      }, 
      ex => o.OnError(ex), 
      () => o.OnCompleted() 
      )); 
} 

तब आपके द्वारा वर्णित व्यवहार प्राप्त करने के लिए इस विधि द्वारा किसी भी अवलोकन योग्य को लपेटा जा सकता है।