结合多个条件 Observable 来准备数据

Question

我有两个stores 需要准备合并数据

1. 获取所有部门（前 50 个部门）
2. 获取所有用户（例如：1000 用户）

我想合并数据并准备最终数据。 注意：部门会要求加载所有用户（这可能需要一些时间），并且不知不觉地，users 不能自己做任何事情，因为他们需要 department 数据来准备最终结果。

这里是department：

      this.store.select(getUserInfo).subscribe((info) => {
        this.store.select(getAllDepts).subscribe((depts) => {
          if (depts.length < 1) {
            this.store.dispatch(loadDeptStore({ accountId: info.acntId}));
          } else {
            console.log(depts);  // get Dept data
          }
        });
      })

对于Users 我拥有的数据：

      this.store
        .select(getUserInfo)
        .pipe(
          flatMap((info) => {
            this.acntName = info.acntId;
            return this.store.select(getAllUsers, { accountId: info.acntId });
          })
        )
        .subscribe((res) => {
          if (res.length < 1 ) {
            this.store.dispatch(loadUsersInAccountStore({ billingCrmAccountId: this.acntName }));
          } else {
            console.log(res); // get users data
          }
        })

我应该使用combineLates 或其他东西吗，如果是，我应该如何使用 RxJS 功能以反应的方式做到这一点。

Answer 1

首先，不要在订阅中进行订阅，这是一种反模式。始终使用更高的可观察量。我不知道代码是如何工作的，因为我不使用 ngrx，但你可以像这样构建你的 observable：

    const userInfo$ = this.store.select(getUserInfo);
    userInfo$.pipe(
        mergeMap(info => {
            this.acntName = info.acntId;
            const departments$ = this.store.select(getAllDepts)
                .pipe(
                    map(depts => {
                        if (depts.length < 1) {
                            return this.store.dispatch(loadDeptStore({ accountId: info.acntId}));
                        } else {
                            return depts;  // get Dept data
                        }
                    })
                );
            const users$ = this.store.select(getAllUsers, { accountId: info.acntId })
                .pipe(
                    map(res => {
                        if (res.length < 1 ) {                          
                            return this.store.dispatch(loadUsersInAccountStore({billingCrmAccountId: this.acntName }));
                        } else {
                            return res; // get users data
                        }
                    })
                );
            return combineLatest([departments$, users$]); 
        }),
        map(([depts, users]) => {
            // do stuffs and return something
        })
    ).subscribe(res => console.log('results: ', res));
        

当你的两个 observables 都发出一次时，CombineLatest 就会发出。每次有一个可观察对象发射时，它都会再次发射。
它可能不适用于您当前的实现，但您会了解如何组合来自一个来源的两个可观察对象。