如何将多个 rxjs observables 与单个订阅结合起来？

Question

我有一个要获取 users 的可观察对象，然后我想调用 API 为每个用户获取 roles，然后将所有数据组合成一个用于显示的对象数组。

我已经到了这一步，但我认为必须有一种方法可以让我将角色调用与流中的用户结合起来，而不是必须先订阅然后再组合最新：

  this.getAllUsersParams$
    .pipe(
      switchMap(params => this.userFacadeService.sysadminGetAllUsers(params)),
      map(allUsers => {
        const rolesCalls: Observable<UserRoles[]>[] = [];

        allUsers.users.forEach(user => {
          rolesCalls.push(this.userFacadeService.getUserRoles(user.id));
        });

        return { allUsers, rolesCalls };
      })
    )
    .subscribe(data => {
      combineLatest(data.rolesCalls)
        .pipe(
          map(userRoles => {
            const userListVM: UserListVM[] = data.allUsers.users.map((user, i) => {
              return {
                ...user,
                roles: userRoles[i],
              };
            });
            return { userListVM, total: data.allUsers.total };
          })
        )
        .subscribe(data => {
          // consume data
        });
    })

Answer 1

您在找这样的东西吗？

this.getAllUsersParams$
  .pipe(
    switchMap(params => this.userFacadeService.sysadminGetAllUsers(params)),
    switchMap(allUsers => combineLatest(
      allUsers.users.map(user => combineLatest([
        of(user),
        this.userFacadeService.getUserRoles(user.id),      
      ])
    )),
    map((result): { total: number, userListVM: UserListVM[] } => ({
      total: result.length,
      userListVM: result.map(user => ({
        ...user[0],
        roles: user[1]
      }))
    }))
  )
  .subscribe(data => {
    ...
  });

它将每个用户与他们的角色配对，然后您可以操纵数据成为您想要的结构。

如何将多个 rxjs observables 与单个订阅结合起来？

How to combine multiple rxjs observables with a single subscription?

javascript

observable

rxjs

angular