如何合并来自参考的阵列的角火结果

Question

我有一个从 angularfire 检索到的引用数组

this.userIds$ = this.users$.switchMap(email =>
  db.list('/USERS/', ref => {
    let temp = email ? ref.orderByChild('EMAIL').startAt(email).endAt(email + "\uf8ff") : ref
    console.log('carrot');
    return temp;
  }
  ).snapshotChanges()
);

我试图将此数据作为一个可观察的数据返回，但是虽然我可以看到填充正确数据库引用的路径，但什么时候说完我的配置数组只包含几千个“未定义”条目我在做什么错误的？我尝试了各种方法，但结果总是一样，所以我将问题浓缩到下面，希望得到一些帮助

//Subscribe to the output of user ids, when we get a hit (delivered as an array of Observable DataSnapshot) loop through and subscribe to all the children of this location
    this.userConfigs$ = this.userIds$.pipe(
      switchMap(itemIds => {
        let configs = itemIds.map(itemId => {
          let pathOrRef = '/AIS/USERSAVEDCONFIGS/' + itemId.key;
          console.log('tomato');
          db.list(pathOrRef).snapshotChanges(['child_added']);
        });
        return configs;
      })
    );

然后我就开始了

this.userConfigs$.subscribe();

Answer 1

你传递给switchMap 的函数应该返回一个 Observable，你返回的是一个数组。我认为 TypeScript 编译器应该警告你。

如果我理解正确，您希望获取一个 itemId 数组，为每个项目进行数据库调用，然后返回一个 pathOrRef 数组。

如果是这样，这样的事情应该可以工作：

1. 使用from() 一次发出一个userIds
2. 使用map() 将项目转换为pathOrRef
3. 使用switchMap() 进行数据库调用
4. 使用mapTo()返回pathOrRef
5. 使用toArray() 将发射放入数组中

this.userConfigs$ = this.userIds$.pipe(
  switchMap(itemIds => from(itemIds).pipe(
    map(itemId => `/AIS/USERSAVEDCONFIGS/${itemId}`),
    switchMap(pathOrRef => fakeDatabaseCall(pathOrRef).pipe(mapTo(pathOrRef)))
  )),
  toArray()
);

这是StackBlitz上的示例