相結合的可能（超時/錯誤）異步網頁結果

局部結果我有兩個方法都返回的IObservable相結合的可能（超時/錯誤）異步網頁結果

IObservable<Something[]> QueryLocal();

和

IObservable<Something[]> QueryWeb();

QueryLocal總是成功的。 QueryWeb容易出現超時和可能的網絡錯誤。

我希望實現一個QueryLocalAndWeb（），它可以調用並組合它們的結果。到目前爲止，我有：

IObservable<Something[]> QueryLocalAndWeb() 
{ 
    var a = QueryLocal(); 
    var b = QueryWeb(); 
    var plan = a.And(b).Then((x, y) => x.Concat(y).ToArray()); 
    return Observable.When(plan).Timeout(TimeSpan.FromSeconds(10), a); 
}

但是，我不知道它處理這樣的情形QueryWeb產生錯誤的情況。將來我可能會有一個QueryWeb2（），這也需要考慮。

那麼，如何組合來自大量IObservables的結果，而忽略那些拋出錯誤（或超時）的結果呢？

來源

2011-09-05 Jesper Larsen-Ledet

我想OnErrorResumeNext應該能夠處理這種情況：

從MSDN：

繼續是正常或終止的觀察到的序列一個異常與下一個可觀察的序列。

IObservable<Something[]> QueryLocalAndWeb() 
{ 
    var a = QueryLocal(); 
    var b = QueryWeb().Timeout(TimeSpan.FromSeconds(10)); 
    return Observable.OnErrorResumeNext(b, a); 
}

您可以通過返回的觀察到使用聚合做陣列的CONCAT。我假設本地和網絡都是冷觀察，即只有當某人訂閱它們時纔開始生成值。

來源

2011-09-06 12:10:40 Ankur

看起來很有趣，雖然很容易混淆命名爲如果拋出會發生什麼？它會傳播嗎？ –

如何：

var plan = a.And(b).Then((x, y) => x.Concat(y.Catch(Observable.Empty<Something[]>()).ToArray());

來源

2011-09-05 22:24:23

如果b拋出並且滿意？（b.Catch（empty））。然後（... –

嗯，它可能不會，可能會更好地把'b'''' –

相結合的可能（超時/錯誤）異步網頁結果

回答

相關問題