RxJS 是一种用于处理数据流和异步代码的 JavaScript 库，它提供了丰富的操作符来简化代码的编写。在 RxJS 操作符中，switchMap 和 exhaustMap 是两个常用的操作符，它们可以帮助我们在处理数据流的过程中实现不同的功能。
switchMap 操作符
switchMap 操作符可以将一个 observable 序列转换为另一个 observable 序列，并只发出最新值。这个操作符很有用，特别是在处理 HTTP 请求和用户输入等场景下。
下面是 switchMap 的示例代码：
// javascriptcn.com 代码示例
setInterval(() => {
const obs = from([1, 2, 3]);
obs.pipe(
switchMap(val => {
return of(val * 10);
})
).subscribe(result => {
console.log(result);
});
}, 1000);在这个例子中，我们创建了一个 setInterval 定时器，每秒钟向 observable 发送一个值。我们使用 switchMap 将这个值序列转换为 10 的倍数的值序列，并发出最新值。
switchMap 操作符的特点是：只会订阅最新的 observable 序列，而忽略之前的所有序列。这个特性可以用于避免重复的 HTTP 请求或用户输入等问题。因此，在处理这些场景时，我们可以使用 switchMap 操作符来优化代码。
exhaustMap 操作符
exhaustMap 操作符和 switchMap 操作符非常相似，它也可以将一个 observable 序列转换为另一个 observable 序列。不同的是，exhaustMap 操作符只会在当前 observable 完成后才会订阅下一个 observable。
下面是 exhaustMap 的示例代码：
const obs = from([1, 2, 3]);
obs.pipe(
exhaustMap(val => {
return of(val * 10).pipe(delay(1000));
})
).subscribe(result => {
console.log(result);
});在这个例子中，我们创建了一个 observable 序列，使用 exhaustMap 将每个值转换为 10 的倍数的值，但是每个转换的 observable 都被设置了一个延迟时间 1 秒。这意味着，每当一个 observable 还没有完成时，exhaustMap 操作符会忽略传入的所有值，直到这个 observable 完成后才会订阅下一个 observable。
exhaustMap 操作符的特点是：等待当前的 observable 完成后再订阅下一个 observable。这个特性可以用于避免同时发出多个 HTTP 请求或用户输入等问题。因此，在处理这些场景时，我们可以使用 exhaustMap 操作符来优化代码。
总结
switchMap 和 exhaustMap 操作符是 RxJS 中非常有用的操作符，它们有着不同的特点和用途。switchMap 操作符可以避免重复的 HTTP 请求或用户输入等问题，而 exhaustMap 操作符可以避免同时发出多个 HTTP 请求或用户输入等问题。因此，在 RxJS 操作符链中，我们可以根据不同的场景来选择使用这两个操作符，从而优化代码的编写。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/653364ec7d4982a6eb6ec9cb