RxJS 流操作失效排查：of 与 from 的区别
在使用 RxJS 处理数据流时，常常会遇到一些看似简单的操作却无法得到预期结果的情况。本文分析一个常见问题：如何使用 RxJS 找出数字数组中的偶数并将其乘以 2，并解释为什么使用 of 操作符会失效。
问题描述:
用户希望使用 RxJS 对一个包含数字的数组进行操作，筛选出偶数并将其值乘以 2。但使用以下代码，控制台没有输出任何数据：
import { of } from 'rxjs';
import { map, filter } from 'rxjs/operators';
const e = of([1, 2, 3, 4, 5]);
e.pipe(
filter(item => item % 2 === 0),
map(num => num * 2)
).subscribe(v => console.log(v));
问题原因:
问题的核心在于 of 操作符的用法。of 操作符将传入的参数作为一个整体发射出去，而不是将其拆分成单个元素。在上述代码中，of([1, 2, 3, 4, 5]) 将整个数组 [1, 2, 3, 4, 5] 作为一个单一元素发射，而不是发射数组中的每个数字。因此，filter 操作符会对整个数组进行操作，而不是对数组中的每个数字进行单独判断。由于数组本身不是偶数，filter 条件 item % 2 === 0 返回 false，导致后续 map 操作不会执行，最终没有输出。
解决方案:
为了正确处理数组中的每个数字，需要使用 from 操作符。from 操作符可以将数组拆分成单个元素进行发射，从而使 filter 和 map 操作符能够正确地对每个数字进行操作。
修正后的代码如下：
import { from } from 'rxjs';
import { map, filter } from 'rxjs/operators';
const e = from([1, 2, 3, 4, 5]);
e.pipe(
filter(item => item % 2 === 0),
map(num => num * 2)
).subscribe(v => console.log(v));
这段代码使用 from 操作符将数组转换成一个可观察对象，其中每个数字都是一个单独的事件。filter 操作符会对每个数字进行偶数判断，map 操作符会将偶数乘以 2，最终 subscribe 函数会将结果打印到控制台。
通过这个例子，我们可以清晰地看到 of 和 from 操作符在处理数组时的区别，以及如何选择合适的操作符来实现预期的 RxJS 数据流操作。 理解这些差异对于编写高效且正确的 RxJS 代码至关重要。
