在RxJS中实现for-await-of语句

基础概念

for-await-of 是 JavaScript 中的一个语法，用于遍历异步迭代器（async iterable）返回的值。它允许你在 for 循环中等待每个 Promise 解析，并处理解析后的值。

RxJS 是一个用于处理异步数据流的库，提供了丰富的操作符和工具来处理 Observable 对象。Observable 是一种数据流，可以发出多个值，这些值可以是同步的，也可以是异步的。

类型

异步迭代器：一个返回 Promise 的迭代器。
Observable：RxJS 中的数据流对象。

应用场景

当你有一个异步迭代器返回的 Promise 数组，并且你想等待每个 Promise 解析并处理其结果时，可以使用 for-await-of 结合 RxJS。

示例代码

假设我们有一个返回 Promise 的数组，并且我们想使用 RxJS 处理这些 Promise 的结果：

const { from } = require('rxjs');
const { map } = require('rxjs/operators');

// 模拟一个返回 Promise 的数组
const promiseArray = [
  Promise.resolve(1),
  Promise.resolve(2),
  Promise.resolve(3)
];

// 将 Promise 数组转换为 Observable
const observable = from(promiseArray);

// 使用 RxJS 操作符处理 Observable
observable.pipe(
  map(value => value * 2) // 将每个值乘以 2
).subscribe({
  next: value => console.log(value), // 输出处理后的值
  complete: () => console.log('Done')
});

遇到的问题及解决方法

问题：为什么 `for-await-of` 不能直接用于 RxJS 的 Observable？

原因：for-await-of 是用于遍历异步迭代器返回的值，而 RxJS 的 Observable 是一种数据流，不是异步迭代器。

解决方法：使用 RxJS 提供的操作符来处理 Observable，如 map、filter、reduce 等。

示例代码

const { from } = require('rxjs');
const { map } = require('rxjs/operators');

// 模拟一个返回 Promise 的数组
const promiseArray = [
  Promise.resolve(1),
  Promise.resolve(2),
  Promise.resolve(3)
];

// 将 Promise 数组转换为 Observable
const observable = from(promiseArray);

// 使用 RxJS 操作符处理 Observable
observable.pipe(
  map(value => value * 2) // 将每个值乘以 2
).subscribe({
  next: value => console.log(value), // 输出处理后的值
  complete: () => console.log('Done')
});