我正试图将我的头包裹在 RX 周围,但我的大脑在某个地方爆炸了:)
我想做的是通过 RX 以异步方式调用 WCF 方法。 这里没什么特别的,但是当 WCF 方法抛出错误时,我想重新创建 channel 并再试一次(最多 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>
,这让我可以捕获异常并继续使用相同的可观察对象,从而给了我想要的东西。
唯一的问题是它永远运行,这意味着如果我继续抛出异常,事情就永远不会停止!
最佳答案
尝试这样做:
var retryable = Observable.Defer(() => _observableFunc(666).Retry(3));
Retry
扩展方法“重复源可观察序列指定的次数或直到它成功终止。”
此外,不要这样做:
var _observable = _observableFunc(666);
var _defered = Observable.Defer(() => _observable);
在您启动 Observable 后,推迟它是没有意义的。
你应该这样做:
var _defered = Observable.Defer(() => _observableFunc(666));
那么你离我在顶部建议的解决方案只有一步之遥。
关于c# - RX,重试并允许处理异常,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/12475556/