RxJS 是一种流式编程库，可以帮助我们更轻松地处理异步事件。在使用 RxJS 时，订阅是一个基本概念。RxJS 提供了多种订阅方式，本文将介绍五种常用的订阅方式，包括 subscribe、forEach、toPromise、toPromiseGuarded、createSubscribeFunction。
1. subscribe
subscribe 是订阅一个 Observable 最常用的方式。当使用 subscribe 订阅一个 Observable 时，我们需要传递一个回调函数作为参数，这个回调函数用于处理 Observable 发出的每个数据项。
-- -------------------- ---- ------- ----- - ---------- - - ----- ----- ----------- - --- ------------------- -- - ----------------------- ----------------------- --- ----------------------- ----- ----- -- ------------------- ------ ----- -- --------------------- --------- -- -- ------------------------ ---展开代码
在上面的示例中，我们新建了一个 Observable，它会发出两个数据项。然后我们使用 subscribe 订阅这个 Observable，并传入一个对象作为参数，对象中包含了三个回调函数。分别是处理数据项(next)、处理错误(error)、处理完成(complete)。
2. forEach
forEach 是订阅 Observable 进行数据处理的另一种方式，它适用于在处理数据过程中不想随时取消订阅。forEach 方法与 subscribe 方法的最大区别在于它返回一个 Promise 对象，可以在 Promise 的 then 方法中处理 Observable 发出的数据项。
const { from } = rxjs; const arrayObservable$ = from(['hello', 'world']); arrayObservable$.forEach(value => console.log(value)) .then(() => console.log('complete')) .catch(error => console.error(error));
在上面的示例中，我们使用 from 方法将一个数组转换成一个 Observable，然后使用 forEach 订阅这个 Observable，并处理它发出的数据项。最后，我们可以通过返回的 Promise 对象来处理完成的事件和错误事件。
3. toPromise
当我们需要把 RxJS 的 Observable 转换成 ES6 的 Promise 对象时，可以使用 toPromise 方法。它会在 Observable 发出自己的 最后一个 数据项或 complete 事件的时候，把 Observable 转换成一个 Promise 对象。
const { interval } = rxjs; const timerObservable$ = interval(1000).pipe(take(5)); timerObservable$.toPromise() .then(() => console.log('complete')) .catch(error => console.error(error));
在上面的示例中，我们使用 interval 方法创建一个定时器 Observable，并使用 take 操作符只取前五个数据项。然后我们使用 toPromise 方法将这个 Observable 转换成一个 Promise，可以在 Promise 对象的 then 方法中处理完成事件和错误事件。
4. toPromiseGuarded
当完成事件和错误事件都被处理了，则 toPromiseGuarded 方法工作与 toPromise 方法相同。但是，当完成事件或错误事件未处理时，它会抛出一个错误。
const { timer } = rxjs; const timerObservable$ = timer(1000); timerObservable$.toPromiseGuarded() .then(() => console.log('complete')) .catch(error => console.error(error));
在上面的示例中，我们使用 timer 方法创建一个定时器 Observable。然后我们使用 toPromiseGuarded 将 Observable 转换成一个 Promise，可以在 Promise 对象的 then 方法中处理完成事件和错误事件。请注意，由于我们没有传递任何参数给 timer 方法，因此它只发布一个完成事件。
5. createSubscribeFunction
除了上述这些订阅方式，我们还可以使用 createSubscribeFunction 函数来定义自己的订阅方式。这个函数接收一个回调函数作为输入。例如，下面的代码定义了一个订阅方式，仅输出奇数数据项。
-- -------------------- ---- ------- ----- - ----------- ----------------------- - - ----- ----- ----------- - --- ------------------- -- - ----------------- ----------------- ----------------- ----------------- ----------------- -------------------- --- ----- --------------- - -------------------------------- -- - ----- ------------ - ----------------------- ----- ----- -- - -- ------ - - --- -- --------------------- -- ------ ----- -- ---------------------- --------- -- -- -------------------- --- ------ -- -- --------------------------- --- ----------------- ----- ----- -- ------------------- ------ ----- -- --------------------- --------- -- -- ------------------------ ---展开代码
在上面的示例中，我们定义了一个 Observable，它会发出五个数据项。然后我们使用 createSubscribeFunction 创建了一个订阅方式，只会输出奇数数据项。最后我们使用这个自定义的订阅方式订阅这个 Observable。
结束语
本文介绍了 RxJS 的五种常用订阅方式，包括 subscribe、forEach、toPromise、toPromiseGuarded、createSubscribeFunction，并提供了示例代码。这些订阅方式在不同的场景下都能发挥作用，并且有助于我们更好地处理异步事件。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/67b8db86306f20b3a670056e
