RxJS

Question

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

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),
      ))

RxJS - Epic Reads Only 1 Promise

RxJS - Epic Reads Only 1 Promise

javascript

promise

epic