RX，重试并允许处理异常答案

【问题标题】：RX, retry and allow to handle exceptionRX，重试并允许处理异常
【发布时间】：2012-09-18 10:53:39
【问题描述】：

我正试图将我的头绕在 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>，它允许我捕获异常并继续使用相同的可观察对象，从而给了我想要的东西。唯一的问题是它永远运行，这意味着如果我继续抛出异常，事情就永远不会停止！

【问题讨论】：

看看 Observable.Retry 是否有帮助。另外，如果您刚刚开始使用 RX，并且您的大脑没有受到伤害，那么您就错了 ;-)
对我的大脑来说是正确的，但它的伤害比昨天少:) 我已经发现了重试，但问题是我的“热”可观察对象仍然“热，我没有得到重点完全推迟语法。

标签： c# .net system.reactive observable

【解决方案1】：

尝试这样做：

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

Retry 扩展方法“重复源 observable 序列指定的次数或直到它成功终止。”

另外，不要这样做：

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

在你启动 observable 之后推迟它是没有意义的。

你应该这样做：

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

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

【讨论】：

是的，我昨天发现了它，就像“啊哈，现在说得通了”。即将发布我做错了什么，但你的回答说明了一切。无论如何，谢谢！！！