链接rxjs 6可观测数据

Question

我必须创建一个ajax请求队列，并对结果进行分组，但我不知道如何做到这一点。

假设我有这样一个数组：

const actors = [
  "Al Pacino",
  "Robert De Niro"
];

我必须对其进行迭代，并对每个值进行api调用：

export const getMovies = action$ =>
  action$.pipe(
    ofType(LOAD_REQUEST),
    // iterate over the array
    // make api call with the actor name
    // for each result, make a second api call with the id of the actor (get in the response.results.id)
    // group the result in an array with all films of all actors of the array passed in the payload
  );

我被switchMap卡住了烟斗..。也不知道怎样才能做到这一点。

编辑尝试了解决方案Valeriy，但得到了以下错误：

export const getMovies = action$ =>
  action$.pipe(
    ofType(LOAD_REQUEST),
    switchMap(({ payload }) =>
      combineLatest(
        payload.map(a => {
          return ajax
            .getJSON(actor(a))
            .pipe(map(response => console.log(response)));
        })
      )
    )
  );


TypeError: You provided 'function (source) {
    return source.lift.call(Object(_observable_from__WEBPACK_IMPORTED_MODULE_2__["from"])([source].concat(observables)), new _observable_combineLatest__WEBPACK_IMPORTED_MODULE_1__["CombineLatestOperator"](project));
  }' where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.

Answer 1

如果我对你的理解是正确的，你就是在试图实现这样的目标：

export const getMovies = action$ => action$.pipe(
    ofType(LOAD_REQUEST),
    switchMap(() => {
        // group the result in an array with all films of all actors of the array passed in the payload
        return combineLatest(
            // iterate over the array
            ...actors.map(actorName => {
                // make api call with the actor name
                return loadActor(actorName).pipe(
                    // for each result, make a second api call with the id of the actor (get in the response.results.id)
                    switchMap(response => loadActorFilms(response.results.id))
                );
            })
        );
    })
);

我使用combineLatest将多个可观察到的数据组合在一起。