Каков наилучший способ организовать последовательность процессоров данных с .net RX?

- а. Вызовите методы на наблюдаемых, какobservable.Do(log).Select(transformation).Do(work).Aggregate(someState)...

- б. Реализация пользовательских наблюдателей, если так - как их связать

- в. Другой вариант. А также, что является лучшим вариантом для обработки возможных исключений в самой наблюдаемой (см. Мои проблемы выше) и для обработки исключений внутри Do, Select и т. Д. (Насколько я знаю, лучшая практика заключается в том, что подписчики не должны 'т бросить).

Также мне иногда нужно разрешить возвращение исключений в виде некоторых элементов наблюдаемой последовательности без остановки последовательности (см. Этот вопросОбработка исключений в реактивных расширениях без остановки последовательности)