在RxJS中發生錯誤可分割

Question

有了承諾，我們可以使用變體.then在發生錯誤時分割鏈。下面是使用fetch

fetch('http://website.com').then(
    // Perform some logic 
    (response) => response.json().then(({ answer }) => `Your answer: ${answer}`), 
    // Skip json parsing when an error occurs 
    (error) => 'An error occurred :(', 
).then(console.log); 

一個例子這讓我跳過響應處理邏輯，只會在原有取聲明中提出的錯誤迴應。東西RxJS相似可能是這樣的：

Observable.fromPromise(fetch('http://website.com')) 
    // if I put .catch here, the result will be piped into flatMap and map 
    .flatMap(response => response.json()) 
    .map(({ answer }) => `Your answer: ${answer}`) 
    // if I put .catch here, errors thrown in flatMap and map will also be caught 
    .subscribe(console.log); 

如上代碼狀態的評論，我不能簡單地把一個catch運營商，因爲它不具有相同的行爲，我的諾言鏈。

我知道我可以通過自定義操作符來獲得它，包括實現或合併一個錯誤捕捉observable與這個，但這一切似乎是非常重大的矯枉過正。有沒有簡單的方法來實現承諾鏈行爲？

Answer 1

其實，如果我在你的情況下，我不會擔心從flatMap和map捕捉錯誤。當源Observable拋出一個錯誤時，它將被傳播給觀察者。所以打電話時我只用一個錯誤處理程序訂閱（否則錯誤被重新拋出）：

.subscribe(console.log, err => console.log('error:', err)); 

注意，當在源可觀察（許諾你的情況）出現錯誤，它的傳播爲error通知，而不是標準的next通知。 這意味着flatMap()和map()將不會對錯誤消息有任何影響。如果您使用的是catch()或materialize()，則兩個運算符（flatMap和map）必須能夠處理此類型的數據（並且不會引發另一個錯誤）。

反正你可以隨時使用share()或publish()，使兩種不同的訂閱，每個只處理一種類型的信號：

let source = Observable.fromPromise(fetch('http://website.com')).publish(); 

source 
    .subscribe(undefined, err => console.log(err)); 

source 
    .flatMap(...) 
    .map(...) 
    .subscribe(console.log,() => {}); 

source.connect(); 

現在我只有錯誤的獨立觀察者。

請注意，我必須使用() => {}進行空回調，以免錯誤被忽略。還要注意，當使用多播時（publish()運算符），那麼Subject裏面可能有一些我應該知道的特定行爲，但在你的用例中可能並不重要。