Архитектура ПО. Rx .NET

Всем привет! Недавно столкнулся с интересной задачей которая была решена "на коленке" и теперь ее нужно довести до ума. Суть такова. Нам по http приходят различные объекты. После получения, объекту необходимо пройти некоторое количество шагов валидации. После успешной валидации сообщение отправляется другому сервису. в зависимости от режима обработки, мы можем ждать или не ждать ответа от другого сервиса. Но результат валидации мы все равно отправляем обратно. Каждый валидатор, в текущем решении бросает exception в случае не прохождения валидации. Если все ок, передает сообщение следующему. Также объекты могут быть нескольких типов и в зависимости от типа, строятся различные комбинации валидаторов.

Вопросов два.

1. Как красиво генерировать цепочку валидаторов?
2. Ка это все завернуть в RX .NET ? Суть такова, что незахедленный exception ломает RX pipeline. А передавать кастомный объект с флагом результата предыдущей валидации по пайпу и в каждом валидаторе его проверять не хочеться.

И конечно все объекты обрабатываются асинхронно.

Я думаю, что с потоковой обработкой кто то да сталкивался и может быть поделиться опытом.

Спасибо всем)