在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里面可能有一些我应该知道的特定行为，但在你的用例中可能并不重要。