RxJS技术疑问：如何在订阅完成后返回Observable？orgsArr提前返回

你的问题核心在于RxJS的异步特性：你循环发起的valueChanges().subscribe()都是异步执行的，而return Observable.of(orgsArr)在这些异步操作完成前就执行了，所以返回的数组是空的。

要实现"所有订阅完成后再返回Observable"，我们可以用RxJS的forkJoin操作符（适合等待多个Observable都完成的场景），结合一些小调整来解决：

修改后的代码 #

import { forkJoin } from 'rxjs';
import { take } from 'rxjs/operators';

// ...

getOrganizations(): Observable<Organization[]> {
  // 1. 先收集所有需要订阅的Observable
  const orgObservables = organizations.map(orgid => {
    // 用take(1)确保Firestore的valueChanges只取一次值就完成
    // 因为valueChanges默认是持续监听的，forkJoin需要Observable完成才会收集结果
    return this.afs.collection('users').doc<Organization>(orgid).valueChanges()
      .pipe(take(1));
  });

  // 2. 用forkJoin等待所有Observable完成，返回结果数组
  return forkJoin(orgObservables);
}

关键细节解释 #

• forkJoin的作用：它接收一个Observable数组，会等待数组中所有Observable都完成后，发出一个包含所有Observable结果的数组（顺序和原数组一致）。
• take(1)的必要性：Firestore的valueChanges()是一个持续发射数据的Observable（当文档更新时会不断发新值），如果不加take(1)，这个Observable永远不会完成，forkJoin会一直等待下去，永远不会返回结果。加take(1)后，我们只取第一次的文档值，然后让Observable完成。
• 不需要手动维护orgsArr：forkJoin会自动把所有结果整理成数组返回，省去了手动push的步骤，代码更简洁可靠。

如果需要实时更新（可选） #

如果你希望持续监听所有组织文档的更新（而不是只取一次值），可以把forkJoin换成combineLatest，它会在任意一个Observable发出新值时，返回所有Observable的最新值数组：

import { combineLatest } from 'rxjs';

// ...

getOrganizations(): Observable<Organization[]> {
  const orgObservables = organizations.map(orgid => {
    return this.afs.collection('users').doc<Organization>(orgid).valueChanges();
  });

  return combineLatest(orgObservables);
}

内容的提问来源于stack exchange，提问作者Mohamed Abo Elmagd