RX，重试并允许处理异常

Question

我试图围绕RX进行思考，但是我的大脑在某个地方爆炸了:)

我正在尝试做的是通过 RX 以异步方式调用 WCF 方法。这里没什么特别的，但是当 WCF 方法抛出错误时，我想重新创建通道并再试一次（最多 3 次）。

到目前为止，我所拥有的是：

var _sc = new Service.Service1Client();
var _observableFunc = Observable.FromAsyncPattern<int, string>(_sc.BeginGetData, _sc.EndGetData);
var _observable = _observableFunc(666);
var _defered = Observable.Defer(() => _observable);
// Here something should be done, but don't know what...
using (_retryable.Subscribe(x => Console.WriteLine("Async ==> '{0}'", x),
                            ex => Console.WriteLine("Oops ==> {0}", ex.Message)))
{
    Console.ReadLine();
}

我玩了Catch<TSource, TException>，这允许我捕获异常并继续相同的可观察量，从而给了我想要的东西。唯一的问题是它永远运行，这意味着如果我继续抛出异常，事情永远不会停止！

Answer 1

尝试这样做：

var retryable = Observable.Defer(() => _observableFunc(666).Retry(3));

Retry扩展方法"重复源可观察序列指定的次数或直到它成功终止。

另外，不要这样做：

var _observable = _observableFunc(666);
var _defered = Observable.Defer(() => _observable);

在你开始观察之后，推迟

观察对象是没有意义的。

您应该改为这样做：

var _defered = Observable.Defer(() => _observableFunc(666));

那么你离我在顶部建议的解决方案只有一步之遥。