Обработка таймаута изящно на Observable.FromAsyncPattern

Question

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

var observer = Observable.Defer(ObservableFunc) 
    .Concat(Observable.Empty<int>().Delay(TimeSpan.FromSeconds(_pollInterval))) 
    .Timeout(TimeSpan.FromSeconds(_Timeout_s)) 
    .Materialize() 
    .Repeat() 
    .Publish() 
    .RefCount(); 

• Не опрашивать пока кто выписывает (Defer)
• повторного опроса данное время после последнего ответа (а не только keep blindly polling) (Concat/Delay)
• Detect, если опрос не истекло (нет ответа) (Timeout)
• Start снова, если он делает тайм-аут (Repeat)
• Не переадресовывайте for new subscribers, прекратите опрос, когда абонентов больше нет (Publish/RefCount).

Мой вопрос об Materialize посередине. Это (для меня), кажется, довольно элегантный способ позволить TimeoutException «пройти», чтобы подписчики могли узнать об этом. Я просто не уверен, должен ли я позволить ему вести себя как Notification, или, возможно, переделать его в какой-то вид Maybe/Nullable T.

Answer 1

Это не может «претендовать» в качестве ответа, но, вероятно, слишком долго для комментария ... Вздох

Моя кишка говорит: распространение информации о тайм-аут, как Maybe/Nullable.

Рассуждение:

• Вероятно, ни один подписавшись на это не волнует, что причина его не в состоянии произвести значение было, они просто заботятся о том, что следующее значение было недоступно по какой-то причине. (Конечно, я делаю много предположений здесь)

Чтобы капельку, я бы следовать Timeout звонку с Catch что бы впрыснуть/вернуть «нулевое значение» (определяемое как бы вы хотели - Maybe, Nullable<T> и т. Д.), Что делает «форму» результирующего потока более понятным для всех подписчиков.