使用内部订阅将数组映射到另一个数组

Question

我有一个对象数组，我们会说它是关闭类型Objects[]。

我需要将每个对象映射到另一种类型的对象，例如，DestinationObject[] 但是DestinationObject[] 上有一个属性，我需要在 Firebase 中查找，所以我需要订阅，或者 @ 987654324@.

不幸的是，如果我进行订阅，我会返回一个订阅，如果我执行pipe(map())，我会得到一个可观察对象列表，而不是可观察对象列表（即我想要Observable<Object[]> 而不是Observable<Object>[]

代码如下：

  processUsers(users: Users[], groupUsers: Users[]): Observable<MappedUser[]> {
    return groupUsers.map(groupUser => {
      return this.firebaseService.SubscribableFunction(groupUser.id).pipe(map(array => {
        return {
          name: groupUser.name,
          arrayLength: array.length,
        } as MappedUser;
      }));
    });
  }

所以两个简单的数组对象，我们确实返回了一个 MappedUser，但是由于 SubscribableFunction 上的 pipe(map())，它返回一个 Observable，因此第一行的映射返回一个 Observable 列表。这不是我想要的。

你有什么解决办法吗？我已经尝试过 map、mergeMap、from() of()，但它似乎没有按预期工作。

更新 这是请求的可订阅函数：

  SubscribableFunction(userId: string): Observable<Equipment[]> {
    const collection = this.afs.collection<Equipment>('equipment', ref => ref.where('userId', '==', userId));
    return collection.snapshotChanges().pipe(map(items => {
      return items.map(item => {
        return {
          id: item.payload.doc.id,
          ...item.payload.doc.data(),
        } as Equipment;
      });
    }));
  }

Answer 1

你快到了。一旦你将源数组映射到一个可观察的数组，你会以[obs1, obs2, obs3, ...] 之类的东西结束。所以在这里你可以使用 RxJS forkJoin 函数来并行触发所有的 observables 并以对象数组的形式获取结果。

试试下面的

processUsers(users: Users[], groupUsers: Users[]): Observable<MappedUser[]> {
  return forkJoin(groupUsers.map(groupUser => { // <-- return `forkJoin` here
    return this.firebaseService.SubscribableFunction(groupUser.id).pipe(map(array => {
      return {
        name: groupUser.name,
        arrayLength: array.length,
      } as MappedUser;
    }));
  }));
}

现在您可以订阅该功能了

processUsers(...).subscribe(
  res => console.log(res), // would log `[{MappedUser}, {MappedUser}, {MappedUser},... ],
  err => // good practice to handle HTTP errors
);

注意：RxJS forkJoin 只会在所有输入 observables 完成时发出。如果您希望获得来自 observable 的数据流，您可以查看 zip 或 combineLatest。你可以找到它们之间的区别here。