Можно IObservable.Catch продолжить с той же наблюдаемой

Question

Предположим, у вас есть IObservable:

IObservable<long> obs = ...;

Могу ли я сделать следующее, чтобы гарантировать, что наблюдаемое никогда не остановится?

IObservable<long> resilientObs = obs.Catch(obs);

Итак, когда ловится исключение, продолжайте с той же последовательностью, которая сгенерировала исключение.

Answer 1

Вы можете сделать это только с холодной наблюдаемой (т.е. наблюдаемой, которая каждый раз возвращает новую последовательность)

obs.Retry();

Но даже тогда вы не «возобновляете» наблюдаемую, выпросто перезапустите его.

Если вы хотите сохранить постоянное соединение (скажем, веб-сокет, который прерывается из-за ошибки), вам нужна заводская функция + Задержка:

Observable.Defer(() => createNewObservable())
    .Retry();

Чтобы дать вам лучший совет, вы должны рассказать нам, что такое obs и что вы пытаетесь сделать.