如何将Observable<T[]>转换为Observable<T>[]？RxJS技术咨询

当然可以实现，核心思路是先获取原Observable发射的数组，再将数组中的每个元素分别包装成独立的Observable，最终得到Observable类型的数组。

具体实现示例 #

假设我们有一个发射数字数组的Observable：

import { Observable, of } from 'rxjs';

// 原Observable：发射包含多个元素的数组
const source$: Observable<number[]> = of([1, 2, 3, 4]);

// 用于存储拆分后的Observable数组
let splitObservables: Observable<number>[] = [];

// 订阅原Observable，处理发射的数组
source$.subscribe((array) => {
  // 将数组每个元素转换为独立的Observable（这里用of创建同步Observable）
  splitObservables = array.map(item => of(item));
});

关键说明 #

• 因为原Observable是异步发射数据的，所以拆分后的Observable数组会在订阅回调执行后才被赋值。如果需要在异步流程中使用这个数组，建议在回调内部处理后续逻辑。
• 如果原Observable会多次发射不同的数组，每次订阅回调都会更新splitObservables，你可以根据业务需求选择覆盖或追加新的Observable。
• 除了of，你也可以根据需要用from（如果元素是可迭代对象）、interval等操作符创建不同行为的Observable。

内容的提问来源于stack exchange，提问作者Mayhew