RxJS 中的执行顺序详解 ——map、switchMap 和 pipe

前言

RxJS 是一种流行的响应式编程库，它提供了强大的工具来处理异步数据流。在 RxJS 中，有许多操作符可以用来转换和处理数据流。本文将着重介绍 RxJS 中的三个操作符：map、switchMap 和 pipe，并详细解释它们的执行顺序。

map 操作符

map 操作符是 RxJS 中最常用的操作符之一。它可以将数据流中的每个元素映射为一个新的元素。例如，我们可以使用 map 操作符将一个字符串数组转换为一个数字数组：

// www.javascriptcn.com code example
import { from } from 'rxjs';
import { map } from 'rxjs/operators';

const arr = ['1', '2', '3'];
const obs$ = from(arr).pipe(
  map(val => parseInt(val))
);

obs$.subscribe(val => console.log(val)); // 输出 1, 2, 3

在上面的代码中，我们使用 from 操作符将一个字符串数组转换为一个可观察对象，然后使用 map 操作符将每个字符串元素转换为一个数字元素。

需要注意的是，map 操作符并不会改变数据流的结构，它只是将每个元素映射为一个新的元素。因此，map 操作符的执行顺序是在上一个操作符执行完毕之后立即执行。

switchMap 操作符

switchMap 操作符是一个比较复杂的操作符，它可以将一个可观察对象转换为另一个可观察对象。它的作用是在接收到新的值时，取消之前的订阅并创建一个新的订阅。例如，我们可以使用 switchMap 操作符从一个 HTTP 请求中获取数据：

// www.javascriptcn.com code example
import { fromEvent } from 'rxjs';
import { switchMap } from 'rxjs/operators';

const button = document.getElementById('button');
const obs$ = fromEvent(button, 'click').pipe(
  switchMap(() => fetch('https://jsonplaceholder.typicode.com/posts'))
);

obs$.subscribe(response => console.log(response));

在上面的代码中，我们使用 fromEvent 操作符创建一个可观察对象，当用户点击按钮时，它会发出一个事件。然后我们使用 switchMap 操作符将这个事件转换为一个 HTTP 请求，并在每次点击按钮时取消之前的请求并创建一个新的请求。

需要注意的是，switchMap 操作符会在接收到新的值时取消之前的订阅并创建一个新的订阅。因此，如果上一个操作符的执行时间比较长，可能会导致一些问题。此外，在使用 switchMap 操作符时，我们需要特别小心，以避免出现无限循环的情况。

pipe 操作符

pipe 操作符是 RxJS 中最基础的操作符之一。它可以将多个操作符组合在一起，形成一个管道。例如，我们可以使用 pipe 操作符将多个操作符组合在一起：

// www.javascriptcn.com code example
import { from } from 'rxjs';
import { map, filter } from 'rxjs/operators';

const arr = ['1', '2', '3'];
const obs$ = from(arr).pipe(
  map(val => parseInt(val)),
  filter(val => val > 1)
);

obs$.subscribe(val => console.log(val)); // 输出 2, 3

在上面的代码中，我们使用 pipe 操作符将 map 和 filter 操作符组合在一起，形成一个管道。在管道中，数据流会依次经过 map 和 filter 操作符，最终输出符合条件的元素。

需要注意的是，pipe 操作符的执行顺序是从左到右。也就是说，数据流会先经过管道中的第一个操作符，然后再经过第二个操作符，以此类推。

总结

在 RxJS 中，map、switchMap 和 pipe 是三个非常重要的操作符。它们可以帮助我们处理异步数据流，并将数据流转换为我们需要的形式。需要注意的是，这些操作符的执行顺序是非常重要的，我们需要根据具体的业务需求来选择合适的操作符，并正确地组合它们。希望本文可以帮助大家更好地理解 RxJS 中的操作符，并在实际开发中得到应用。

来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/660a2f87d10417a222969d2b