javascript - RxJS - Epic 只读 1 个 Promise

Question

我有一个史诗。我想传递 2 个 HTTP 获取请求。它们都是基于 Promise 的。但它只为第一个处理的数据带来数据。史诗：

const processorsListEpic = (action$, store, deps) =>
  action$.ofType(Type.LIST_ATTEMPT).pipe(
    switchMap(() =>
      observableFromHttpPromise(
        deps.getList(store), // This bring data
        deps.getTargets(store) // This doesn't
      ).pipe(
        mergeMap((listResult, targetResult) => {
          console.log('Target:', targetResult.data);
          console.log('List', listResult.data);
          return of(
            R.mergeAll(
              Actions.ListSuccess(listResult && listResult.data),
              Actions.TargetsSuccess(targetResult && targetResult.data)
            )
          );
        }),
        catchError(error => of(Actions.ListFailure(error)))
      )
    )
  );

功能observableFromHttpPromise如下：

// From is from rxjs
export const observableFromHttpPromise = promise => from(promise);

有任何想法吗？如果我更改请求的顺序，其他数据就在那里..

Answer 1

尝试这个

observableFromHttpPromise(Promise.all(
        deps.getList(store),
        deps.getTargets(store),
      ))