Обработка ошибок с помощью Реактивная Framework

Question

Я разработал то, что по существу PropertyChanged слушателя - то есть, когда Instance.A изменения, вызовите OnAChanged()

Observable.FromEventPattern<PropertyChangedEventArgs>(Instance,"PropertyChanged") 
      .Where(e => e.EventArgs.PropertyName == "A") 
      .ObserveOn(Scheduler.ThreadPool) 
      .Subscribe(search => 
       OnAChanged((PropertyChangedEventArgsEx)search.EventArgs), s => 
        OnError(s)); 

Это работает совершенно нормально (без s => OnError(s) части).

Однако я хотел протестировать обработку исключений. Я изменил метод OnAChanged(), чтобы просто выбросить новое исключение. Однако исключение выбрасывается, и OnError никогда не вызывается, и мое приложение выходит из строя. Я не понимаю использование OnError?

Answer 1

Вы ошибаетесь OnError - OnError является свойством IObservable. На основе событий IObservables никогда не OnError (потому что нет такой вещи, как «Событие Исключение» или что-то еще). Если у вас есть другой источник, например Observable.Start, вы можете увидеть OnError.