前言
RxJS 是一个非常流行的 JavaScript 库，它提供了一种响应式编程的方式来处理异步数据流。在实际应用中，我们经常需要处理错误，RxJS 提供了两种错误处理机制：catch 和 throw。本文将详细介绍这两种机制的使用方法，并通过示例代码演示其应用。
catch 操作符
catch 操作符用于捕获 Observable 中的错误，并返回一个新的 Observable。如果源 Observable 中发生错误，catch 操作符会尝试处理错误并返回一个新的 Observable，这个新的 Observable 可以是一个默认值，也可以是一个新的 Observable。
catch 操作符的基本语法如下：
observable.catch(handler)
其中，handler 可以是一个函数或者一个 Observable。
1. 使用函数处理错误
catch 操作符可以接收一个函数作为参数，用于处理 Observable 中发生的错误。如果源 Observable 中发生错误，则会调用这个函数，并返回一个新的 Observable。
下面是一个简单的示例代码：
const source = Rx.Observable.throw('Oops!');
const example = source.catch((error, caught) => {
console.log(`Caught: ${error}`);
return Rx.Observable.of('default');
});
example.subscribe(value => console.log(value));在上面的代码中，我们创建了一个 Observable，它通过 Rx.Observable.throw 方法抛出了一个错误。然后，我们使用 catch 操作符来捕获这个错误，并将其处理为一个默认值。最后，我们订阅了返回的 Observable，并打印出了它的值。
2. 使用 Observable 处理错误
catch 操作符还可以接收一个 Observable 作为参数，用于返回一个新的 Observable，以处理 Observable 中发生的错误。如果源 Observable 中发生错误，则会订阅这个新的 Observable，并返回它的值。
下面是一个简单的示例代码：
-- -------------------- ---- ------- ----- ------ - ----------------------------- ----- ------- - -------------------- ------- -- - -------------------- ----------- ------ ---------------------------- --- ----- -------- - ----------------------------- ----- ------ - ---------------- -- ---------- ---------------------- -- --------------------
在上面的代码中，我们创建了一个 Observable，它通过 Rx.Observable.throw 方法抛出了一个错误。然后，我们使用 catch 操作符来捕获这个错误，并将其处理为一个默认值。接着，我们又创建了一个 Observable，用于处理 catch 操作符返回的 Observable 中发生的错误，并将其处理为另一个默认值。最后，我们订阅了返回的 Observable，并打印出了它的值。
throw 操作符
throw 操作符用于抛出一个错误，它会立即终止 Observable 的执行，并将错误抛出给订阅者。如果 Observable 中发生错误，订阅者将会接收到这个错误，并对其进行处理。
throw 操作符的基本语法如下：
Rx.Observable.throw(error)
下面是一个简单的示例代码：
-- -------------------- ---- -------
----- ------ - ------------------- -- --
-------------- -- -
-- ------ --- -- -
------ -------------------------- ----- -------- -- --- -----------
-
------ ------------------------
---
-----------------
----- -- ---------------------- -----------
----- -- ------------------- ----------
--在上面的代码中，我们创建了一个 Observable，它通过 Rx.Observable.of 方法返回了一个包含三个数字的 Observable。然后，我们使用 flatMap 操作符来处理这个 Observable，如果当前的值等于 2，则使用 throw 操作符抛出一个错误。最后，我们订阅了这个 Observable，并打印出了它的值或错误。
结论
RxJS 中的 catch 和 throw 操作符可以帮助我们更好地处理 Observable 中的错误。使用 catch 操作符可以捕获 Observable 中的错误，并返回一个新的 Observable，以便我们对错误进行处理。使用 throw 操作符可以抛出一个错误，以便订阅者对其进行处理。在实际应用中，我们可以根据具体情况选择合适的操作符来处理错误。
参考文献
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6746c041e504cb428ec2647d